()

( J joinKey, @Nullable K leftKey, @Nullable L leftValue, @Nullable K rightKey, @

(long numSamples, long parallelism)

(String name)

(Coder<T> valueCoder)

()

( double latitudeDirection, double longitudeDirection, double speedMeterPerSec, long t

(long stamp)

(Position other)

( J joinKey, K primaryKey, Object primaryValue, K otherKey,

(Metric input)

()

()

(String directoryPath)

(start, direction, speed, duration)

()

(InputStream inStream)

(jar="/usr/local/lib/beam-chapter6-1.0.0.jar", args=None)

(String tsv)

(InputStream stream)

(self, port)

(Server server)

(String[] args)

(String input)

()

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

(self, batch, batchSize, flushTimer, endOfTime)

(Path tempDir, int length)

(stamp)

(int port)

(String s, Instant stamp)

(String s, Instant stamp)

(input, shortDuration, longDuration)

(PCollection<String> words)

()

(String value, OutputStream outStream)

( Iterable<ValueWithTimestamp<String>> elements, OutputReceiver<KV<String, Integer>> outputRec

(InputStream stream)

(T value)

( TupleTag<String> mainOutput, TupleTag<String> droppableOutput, PCollection<String> input)

( TupleTag<String> mainOutput, TupleTag<String> droppableOutput, PCollection<String> input)

(String newFile)

(input)

(input)

(input, address="localhost:1234", batchSize=10, maxWaitTime=None)

(input)

(PCollection<String> input, int port)

(PCollection<String> input, int port)

(PCollection<String> input, Params params)

(deltaLatLon)

(deltaLatLon)

(double deltaLatLon)

( BagState<ValueWithTimestamp<String>> elements, ValueState<Integer> batchSize, ValueS

(PCollection<String> lines)

(PCollection<String> lines)

( PCollection<String> lines)

(PCollection<KV<String, Position>> records)

( PCollection<KV<String, Position>> records)

( PCollection<String> lines, Duration windowLength, int k)

(Path tempDir, String file)

(p1, p2)

( BagState<KV<Instant, String>> buffer, boolean closed, MultiOutputReceiver output)

( String element, Instant timestamp, boolean closed, MultiOutputReceiver output)

(Request request)

( MapState<K, P> primary, MapState<K, O> other, K primaryKey, J joinKey,

( SerializableFunction<T, K> keyExtractor, SerializableFunction<T, J> joinKeyExtractor)

(String field)

()

(String[] args)

(Pipeline pipeline)

(Pipeline pipeline)

(self, request, context)

( RequestList requestBatch, StreamObserver<ResponseList> responseObserver)

(String[] args, TimestampCombiner combiner)

(self)

( PCollection<String> result, String bootstrapServer, String topic)

( PCollection<String> result, String bootstrapServer, String topic)

(input, duration)

()

()

(char character, int length)

(List<KV<String, Position>> input)

(List<KV<String, Position>> input)

(PCollection<String> words)

(Position first, Position second)

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

(key, trackPositions)

( Position first, PriorityQueue<Position> queue, Consumer<TimestampedValue<Metric>> ou

(Iterable<Row> positions)

(Instant startOfTenSecondWindow)

(p1, p2)

(self, flush, key)

(KV<String, Boolean> message)

( int numPointsPerTrack, long timeStart, Random random)

( String path, RestrictionTracker<DirectoryWatchRestriction, String> tracker)

()

()

(InputStream stream)

(InputStream stream)

(MetricAccumulator acc)