Rename GlobalWindows.WindowedValue to GlobalWindows.windowed_value

----Release Notes----
[]
-------------
Created by MOE: https://github.com/google/moe
MOE_MIGRATED_REVID=121691420

Author: charlesccychen

google/cloud/dataflow/runners/direct_runner.py

@@ -200,7 +200,7 @@ def run_GroupByKeyOnly(self, transform_node):
                              % wv)
 
     gbk_result = map(
-        GlobalWindows.WindowedValue,
+        GlobalWindows.windowed_value,
         ((key_coder.decode(k), v) for k, v in result_dict.iteritems()))
     self.debug_counters['element_counts'][
         transform_node.full_label] += len(gbk_result)
@@ -209,7 +209,7 @@ def run_GroupByKeyOnly(self, transform_node):
   @skip_if_cached
   def run_Create(self, transform_node):
     transform = transform_node.transform
-    create_result = [GlobalWindows.WindowedValue(v) for v in transform.value]
+    create_result = [GlobalWindows.windowed_value(v) for v in transform.value]
     self.debug_counters['element_counts'][
         transform_node.full_label] += len(create_result)
     self._cache.cache_output(transform_node, create_result)
@@ -230,7 +230,7 @@ def run_Read(self, transform_node):
     source = transform_node.transform.source
     source.pipeline_options = transform_node.inputs[0].pipeline.options
     with source.reader() as reader:
-      read_result = [GlobalWindows.WindowedValue(e) for e in reader]
+      read_result = [GlobalWindows.windowed_value(e) for e in reader]
       self.debug_counters['element_counts'][
           transform_node.full_label] += len(read_result)
       self._cache.cache_output(transform_node, read_result)

google/cloud/dataflow/transforms/window.py

@@ -259,7 +259,7 @@ class GlobalWindows(WindowFn):
   """A windowing function that assigns everything to one global window."""
 
   @classmethod
-  def WindowedValue(cls, value, timestamp=MIN_TIMESTAMP):  # pylint: disable=invalid-name
+  def windowed_value(cls, value, timestamp=MIN_TIMESTAMP):
     return WindowedValue(value, timestamp, [GlobalWindow()])
 
   def assign(self, assign_context):

google/cloud/dataflow/worker/executor.py

@@ -199,7 +199,7 @@ def start(self):
         if reader.returns_windowed_values:
           windowed_value = value
         else:
-          windowed_value = GlobalWindows.WindowedValue(value)
+          windowed_value = GlobalWindows.windowed_value(value)
         self.output(windowed_value)
 
   def request_dynamic_split(self, dynamic_split_request):
@@ -289,7 +289,7 @@ def start(self):
     with self.shuffle_source.reader() as reader:
       for key, key_values in reader:
         self._reader = reader
-        windowed_value = GlobalWindows.WindowedValue((key, key_values))
+        windowed_value = GlobalWindows.windowed_value((key, key_values))
         self.output(windowed_value, coder=write_coder)
 
   def get_progress(self):
@@ -322,7 +322,7 @@ def start(self):
     with self.shuffle_source.reader() as reader:
       for value in reader:
         self._reader = reader
-        windowed_value = GlobalWindows.WindowedValue(value)
+        windowed_value = GlobalWindows.windowed_value(value)
         self.output(windowed_value, coder=write_coder)
 
   def get_progress(self):

google/cloud/dataflow/worker/opcounters_test.py

@@ -48,15 +48,15 @@ def test_update_int(self):
     opcounts = OperationCounters(CounterFactory(), 'some-name',
                                  coders.PickleCoder(), 0)
     self.verify_counters(opcounts, 0)
-    opcounts.update_from(GlobalWindows.WindowedValue(1))
+    opcounts.update_from(GlobalWindows.windowed_value(1))
     opcounts.update_collect()
     self.verify_counters(opcounts, 1)
 
   def test_update_str(self):
     opcounts = OperationCounters(CounterFactory(), 'some-name',
                                  coders.PickleCoder(), 0)
     self.verify_counters(opcounts, 0)
-    opcounts.update_from(GlobalWindows.WindowedValue('abcde'))
+    opcounts.update_from(GlobalWindows.windowed_value('abcde'))
     opcounts.update_collect()
     self.verify_counters(opcounts, 1)
 
@@ -65,7 +65,7 @@ def test_update_old_object(self):
                                  coders.PickleCoder(), 0)
     self.verify_counters(opcounts, 0)
     obj = OldClassThatDoesNotImplementLen()
-    opcounts.update_from(GlobalWindows.WindowedValue(obj))
+    opcounts.update_from(GlobalWindows.windowed_value(obj))
     opcounts.update_collect()
     self.verify_counters(opcounts, 1)
 
@@ -75,19 +75,19 @@ def test_update_new_object(self):
     self.verify_counters(opcounts, 0)
 
     obj = ObjectThatDoesNotImplementLen()
-    opcounts.update_from(GlobalWindows.WindowedValue(obj))
+    opcounts.update_from(GlobalWindows.windowed_value(obj))
     opcounts.update_collect()
     self.verify_counters(opcounts, 1)
 
   def test_update_multiple(self):
     opcounts = OperationCounters(CounterFactory(), 'some-name',
                                  coders.PickleCoder(), 0)
     self.verify_counters(opcounts, 0)
-    opcounts.update_from(GlobalWindows.WindowedValue('abcde'))
-    opcounts.update_from(GlobalWindows.WindowedValue('defghij'))
+    opcounts.update_from(GlobalWindows.windowed_value('abcde'))
+    opcounts.update_from(GlobalWindows.windowed_value('defghij'))
     opcounts.update_collect()
     self.verify_counters(opcounts, 2)
-    opcounts.update_from(GlobalWindows.WindowedValue('klmnop'))
+    opcounts.update_from(GlobalWindows.windowed_value('klmnop'))
     opcounts.update_collect()
     self.verify_counters(opcounts, 3)
 

google/cloud/dataflow/worker/windmillio.py

@@ -58,7 +58,7 @@ def __init__(self, source):
   def __iter__(self):
     for bundle in self.source.context.work_item.message_bundles:
       for message in bundle.messages:
-        yield GlobalWindows.WindowedValue(
+        yield GlobalWindows.windowed_value(
             self.source.coder.decode(message.data),
             timestamp=windmill_to_harness_timestamp(message.timestamp))