MCPcopy Create free account

hub / github.com/dataArtisans/flink-dataflow / functions

Functions813 in github.com/dataArtisans/flink-dataflow

⨍ Functions 813◇ Types & classes 169
MethodFlinkParDoBoundWrapper
(PipelineOptions options, WindowingStrategy<?, ?> windowingStrategy, DoFn<IN, OUT> doFn)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkParDoBoundWrapper.java:38
MethodFlinkPartialReduceFunction
(Combine.KeyedCombineFn<K, VI, VA, ?> keyedCombineFn)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkPartialReduceFunction.java:37
MethodFlinkPipelineExecutionEnvironment
Creates a {@link FlinkPipelineExecutionEnvironment} with the user-specified parameters in the provided {@link FlinkPipelineOptions}. @param options t
runner/src/main/java/com/dataartisans/flink/dataflow/FlinkPipelineExecutionEnvironment.java:79
MethodFlinkPipelineRunner
(FlinkPipelineOptions options)
runner/src/main/java/com/dataartisans/flink/dataflow/FlinkPipelineRunner.java:96
MethodFlinkReduceFunction
(Combine.KeyedCombineFn<K, ?, VA, VO> keyedCombineFn)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkReduceFunction.java:38
MethodFlinkRunnerRegistrar
()
runner/src/main/java/com/dataartisans/flink/dataflow/FlinkRunnerRegistrar.java:35
MethodFlinkRunnerResult
(Map<String, Object> aggregators, long runtime)
runner/src/main/java/com/dataartisans/flink/dataflow/FlinkRunnerResult.java:37
MethodFlinkStateInternals
(K key, Coder<K> keyCoder, Coder<? extends BoundedWind
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:54
MethodFlinkStreamingCreateFunction
(List<byte[]> elements, Coder<OUT> coder)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/io/FlinkStreamingCreateFunction.java:40
MethodFlinkStreamingPipelineTranslator
(StreamExecutionEnvironment env, PipelineOptions options)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkStreamingPipelineTranslator.java:46
MethodFlinkStreamingTranslationContext
(StreamExecutionEnvironment env, PipelineOptions options)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkStreamingTranslationContext.java:45
MethodFlinkTestPipeline
(PipelineRunner<? extends PipelineResult> runner, PipelineOptions options)
runner/src/test/java/com/dataartisans/flink/dataflow/FlinkTestPipeline.java:65
MethodFlinkWatermarkHoldStateImpl
(ByteString stateKey, OutputTimeFn<? super W> outputTimeFn)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:359
MethodGroupByNullKeyTest
()
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/GroupByNullKeyTest.java:48
MethodJoinExamplesITCase
()
runner/src/test/java/com/dataartisans/flink/dataflow/JoinExamplesITCase.java:39
MethodKvCoderComperator
(KvCoder<K, V> coder)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/KvCoderComperator.java:54
MethodKvCoderTypeInformation
(KvCoder<K, V> coder)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/KvCoderTypeInformation.java:42
MethodMaybeEmptyTestITCase
()
runner/src/test/java/com/dataartisans/flink/dataflow/MaybeEmptyTestITCase.java:34
MethodMyCustomSink
(String resultPath)
runner/src/test/java/com/dataartisans/flink/dataflow/WriteSinkITCase.java:81
MethodPassThroughIterable
(KV<K, V> first, Iterator<KV<K, V>> iterator)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkKeyedListAggregationFunction.java:44
MethodProcessContext
(DoFn<KeyedWorkItem<K, VIN>, KV<K, VOUT>> function, TimestampedCollector<WindowedValue
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java:407
MethodProcessContext
(DoFn<IN, OUT> fn, Collector<OUT> outCollector)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkDoFnFunction.java:90
MethodProcessContext
(DoFn<IN, OUT> fn, Collector<RawUnionValue> outCollector)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkMultiOutputDoFnFunction.java:95
MethodRangeReadReader
(PipelineOptions options)
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/UnboundedSourceITCase.java:140
MethodRangeReadSource
(int from, int to)
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/UnboundedSourceITCase.java:102
MethodRangeReader
(ReadSource source)
runner/src/test/java/com/dataartisans/flink/dataflow/ReadSourceITCase.java:130
MethodReadDocuments
(Iterable<URI> uris)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/TFIDF.java:162
MethodReadSource
(int from, int to)
runner/src/test/java/com/dataartisans/flink/dataflow/ReadSourceITCase.java:84
MethodReadSourceITCase
()
runner/src/test/java/com/dataartisans/flink/dataflow/ReadSourceITCase.java:41
MethodRemoveDuplicatesEmptyITCase
()
runner/src/test/java/com/dataartisans/flink/dataflow/RemoveDuplicatesEmptyITCase.java:35
MethodRemoveDuplicatesITCase
()
runner/src/test/java/com/dataartisans/flink/dataflow/RemoveDuplicatesITCase.java:35
MethodSerializableFnAggregatorWrapper
(Combine.CombineFn<AI, ?, AO> combiner)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/SerializableFnAggregatorWrapper.java:39
MethodSinkOutputFormat
(Write.Bound<T> transform, PipelineOptions pipelineOptions)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/SinkOutputFormat.java:50
MethodSourceInputFormat
(BoundedSource<T> initialSource, PipelineOptions options)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/SourceInputFormat.java:52
MethodSourceInputSplit
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/SourceInputSplit.java:35
MethodStateCheckpointReader
(DataInputView in)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/StateCheckpointReader.java:30
MethodStateCheckpointWriter
(AbstractStateBackend.CheckpointStateOutputView output)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/StateCheckpointWriter.java:34
MethodStateType
(int value)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/StateType.java:36
MethodTfIdfITCase
()
runner/src/test/java/com/dataartisans/flink/dataflow/TfIdfITCase.java:37
MethodTopWikipediaSessionsITCase
()
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/TopWikipediaSessionsITCase.java:45
MethodUnboundedFlinkSource
(SourceFunction<T> source)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/io/UnboundedFlinkSource.java:35
MethodUnboundedSocketReader
(UnboundedSocketSource source)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/io/UnboundedSocketSource.java:134
MethodUnboundedSocketSource
(String hostname, int port, char delimiter, long maxNumRetries)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/io/UnboundedSocketSource.java:58
MethodUnboundedSourceITCase
()
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/UnboundedSourceITCase.java:49
MethodUnboundedSourceWrapper
(PipelineOptions pipelineOptions, Read.Unbounded<T> transform)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/io/UnboundedSourceWrapper.java:59
MethodUnionCoder
(List<Coder<?>> elementCoders)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/UnionCoder.java:140
MethodUser
()
runner/src/test/java/com/dataartisans/flink/dataflow/AvroITCase.java:103
MethodVoidValue
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/VoidCoderTypeSerializer.java:107
MethodWordCountITCase
()
runner/src/test/java/com/dataartisans/flink/dataflow/WordCountITCase.java:36
MethodWriteSinkITCase
()
runner/src/test/java/com/dataartisans/flink/dataflow/WriteSinkITCase.java:44
MethodWriteTfIdf
(String output)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/TFIDF.java:413
Methodadd
(InputT input)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:544
MethodaddComparatorField
(int fieldId, TypeComparator<?> comparator)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/KvCoderTypeInformation.java:178
MethodaddInput
(Object key, int[] accumulator, Integer value, CombineWithContext.Context c)
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/StateSerializationTest.java:59
MethodaddValue
(AI value)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/SerializableFnAggregatorWrapper.java:66
Methodadvance
()
runner/src/test/java/com/dataartisans/flink/dataflow/ReadSourceITCase.java:139
Methodadvance
()
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/UnboundedSourceITCase.java:150
Methodapply
( PTransform<Input, Output> transform, Input input)
runner/src/main/java/com/dataartisans/flink/dataflow/FlinkPipelineRunner.java:154
Methodapply
(PInput input)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/TFIDF.java:171
Methodapply
( PCollection<KV<URI, String>> uriToContent)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/TFIDF.java:215
Methodapply
(KV<String, Long> input)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/WordCount.java:73
Methodapply
(PCollection<String> input)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/AutoComplete.java:72
Methodapply
(String input)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/AutoComplete.java:133
Methodapply
( PCollection<CompletionCandidate> input)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/AutoComplete.java:181
MethodbindBag
(StateTag<? super K, BagState<T>> address, Coder<T> elemCoder)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:89
MethodbindCombiningValue
( StateTag<? super K, AccumulatorCombiningState<InputT, AccumT, OutputT>> address, Coder<AccumT> a
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:94
MethodbindKeyedCombiningValue
( StateTag<? super K, AccumulatorCombiningState<InputT, AccumT, OutputT>> address, Coder<AccumT> a
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:101
MethodbindKeyedCombiningValueWithContext
( StateTag<? super K, AccumulatorCombiningState<InputT, AccumT, OutputT>> address, Coder<AccumT> a
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:109
MethodbindValue
(StateTag<? super K, ValueState<T>> address, Coder<T> coder)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:84
MethodbindWatermark
(StateTag<? super K, WatermarkHoldState<W>> address, OutputTimeFn<? super W> outputTimeFn)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:117
MethodbinderForNamespace
(final StateNamespace namespace, final StateContext<?> c)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:80
MethodcanEqual
(Object obj)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/CoderTypeSerializer.java:143
MethodcanEqual
(Object obj)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/CoderTypeInformation.java:99
Methodcancel
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/io/UnboundedSourceWrapper.java:127
Methodclear
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:299
Methodclear
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:364
Methodclear
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:538
Methodclone
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/CombineFnAggregatorWrapper.java:67
Methodclone
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/SerializableFnAggregatorWrapper.java:81
MethodcloneAs
(Class<T> kls)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java:454
Methodclose
()
runner/src/test/java/com/dataartisans/flink/dataflow/WriteSinkITCase.java:141
Methodclose
()
runner/src/test/java/com/dataartisans/flink/dataflow/ReadSourceITCase.java:150
Methodclose
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/SourceInputFormat.java:160
Methodclose
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java:308
MethodcoGroup
(Iterable<KV<K,V1>> first, Iterable<KV<K,V2>> second, Collector<KV<K, CoGbkResult>> out)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkCoGroupKeyedListAggregator.java:42
Methodcombine
(Iterable<KV<K, VI>> elements, Collector<KV<K, VA>> out)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkPartialReduceFunction.java:42
Methodcompare
(Object o1, Object o2)
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/GroupAlsoByWindowTest.java:428
Methodcompare
(KV<K, V> first, KV<K, V> second)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/KvCoderComperator.java:136
MethodcompareSerialized
(DataInputView firstSource, DataInputView secondSource)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/CoderComparator.java:138
MethodcompareSerialized
(DataInputView firstSource, DataInputView secondSource)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/KvCoderComperator.java:160
MethodcompareToReference
(TypeComparator<T> other)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/CoderComparator.java:96
MethodcompareToReference
(TypeComparator<KV<K, V>> other)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/KvCoderComperator.java:117
Methodconfigure
(Configuration configuration)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/SourceInputFormat.java:71
Methodconfigure
(Configuration configuration)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/SinkOutputFormat.java:68
Methodcopy
(T t)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/CoderTypeSerializer.java:77
Methodcopy
(VoidValue from)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/VoidCoderTypeSerializer.java:49
MethodcreateAccumulator
(Object key, CombineWithContext.Context c)
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/StateSerializationTest.java:54
MethodcreateAggregatorInternal
(String name, Combine.CombineFn<AggInputT, ?, AggOutputT> combiner)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java:566
MethodcreateAggregatorInternal
(String name, Combine.CombineFn<AggInputT, ?, AggOutputT> combiner)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java:177
MethodcreateAggregatorInternal
(String name, Combine.CombineFn<AggInputT, ?, AggOutputT> combiner)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkDoFnFunction.java:193
← previousnext →301–400 of 813, ranked by callers