(pos, direction, speed, t)

( WindowFn<T, BoundedWindow> windowFn, Instant timestamp)

()

()

()

(Instant now, int pos)

(Duration duration)

( String line, KafkaProducer<String, String> producer, String outputTopic)

( OutputReceiver<BoundedWindow> output, Instant minStamp, Instant maxStamp)

(String[] args)

(String[] args)

(String[] args)

(String[] args)

(String[] args)

(String[] args)

(String[] args)

(String[] args)

(String[] args)

(String[] args)

(String[] args)

(String[] args)

(String[] args)

(String[] args)

(String[] args)

(String[] args)

( RestrictionTracker<DirectoryWatchRestriction, String> tracker, ManualWatermarkEstimator<Inst

(Pipeline pipeline, Params params)

(Pipeline pipeline, Params params)

(Pipeline pipeline, Params params)

(Pipeline pipeline, Params params)

(Pipeline pipeline, Params params)

(filename)

(Request request, StreamObserver<Response> responseObserver)

( PCollection<T> input, WindowingStrategy<T, BoundedWindow> strategy)

( PCollection<String> input, WindowingStrategy<String, BoundedWindow> strategy)

(int port)

(int port)

(RandomAccessFile file, long position)

(Timer timer, Instant currentStamp, long minTsToKeep)

(PCollection<KV<String, Integer>> result, Params params)

(PCollection<KV<String, Integer>> result, Params params)

(PCollection<KV<String, Integer>> result, Params params)

()

()

()

()

()

()

()

()

()

()

()

(RandomFactory randomFactory)

(SerializableFunction<KV<String, Instant>, Instant> watermarkFn)

(String bootstrapServer, String outputTopic)

(double latitude, double longitude)

(String hostname, int port)

(int maxBatchSize, Duration maxBatchWait, String hostname, int port)

(Coder<JoinRow<K, J, V>> rowCoder)

()

(String name)

(Duration delay)

(SerializableFunction<KV<String, Instant>, Instant> watermarkFn)

(DirectoryWatchRestriction restriction)

( Coder<K> keyCoder, Coder<J> joinKeyCoder, Coder<L> leftValueCoder, Coder<R>

(Coder<K> keyCoder, Coder<J> joinKeyCoder, Coder<V> valueCoder)

( Duration loopDuration, Instant startingTime, WindowingStrategy<KV<String, String>, ?

(boolean includeKey)

(double length, long duration)

()

(long numSamples, long parallelism)

(String bootstrapServer, String inputTopic)

(String hostname, int port)

( Duration allowedLateness, Coder<BoundedWindow> windowCoder, TupleTag<String> mainOut

( Duration allowedLateness, TupleTag<String> mainOutput, TupleTag<String> droppableOutput)

(Coder<K> keyCoder, Coder<L> leftValueCoder, Coder<R> rightValueCoder)

(String directoryPath)

( TupleTag<L> leftHandTag, TupleTag<R> rightHandTag, SerializableFunction<L, K> leftKeyExtra

()

(Coder<T> valueCoder)

(Duration delay)

(String name)

(String bootstrapServer, String outputTopic)

(self)

(self, exc_type, exc_val, exc_tb)

(self, port=None)

(self, address, batchSize, maxWaitTime)

(self, duration)

(List<Row> mutableAccumulator, Row input)

(AverageAccumulator accumulator, String input)

(MetricAccumulator accumulator, Metric input)

(self, acc, element)

(String input)

(x)

()

( KV<String, Iterable<Position>> stringIterableKV)

()

()

()