MCPcopy Create free account

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

Functions813 in github.com/dataArtisans/flink-dataflow

⨍ Functions 813◇ Types & classes 169
↓ 1 callersMethodgetNumberOfExecutionRetries
()
runner/src/main/java/com/dataartisans/flink/dataflow/FlinkPipelineOptions.java:80
↓ 1 callersMethodgetOutput
()
runner/src/test/java/com/dataartisans/flink/dataflow/util/JoinExamples.java:140
↓ 1 callersMethodgetOutput
()
examples/src/main/java/com/dataartisans/flink/dataflow/examples/TFIDF.java:103
↓ 1 callersMethodgetPipelineOptions
For testing.
runner/src/main/java/com/dataartisans/flink/dataflow/FlinkPipelineRunner.java:136
↓ 1 callersMethodgetRecursive
()
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/AutoComplete.java:353
↓ 1 callersMethodgetSideInputDataSet
(PCollectionView<?> value)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkBatchTranslationContext.java:88
↓ 1 callersMethodgetState
()
runner/src/main/java/com/dataartisans/flink/dataflow/FlinkRunnerResult.java:45
↓ 1 callersMethodgetStateInternalsForKey
Gets the state associated with the specified key. @param key the key whose state we want. @return The {@link FlinkStateInternals} associated with tha
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java:374
↓ 1 callersMethodgetTag
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/StateCheckpointReader.java:34
↓ 1 callersMethodgetTagToString
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/StateCheckpointReader.java:38
↓ 1 callersMethodgetTimeToNextWaternark
(long watermarkInterval)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/io/UnboundedSourceWrapper.java:151
↓ 1 callersMethodgetTimersReadyToProcess
Returns the list of timers that are ready to fire. These are the timers that are registered to be triggered at a time before the current watermark. We
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java:340
↓ 1 callersMethodgetWatermark
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/io/UnboundedSocketSource.java:216
↓ 1 callersMethodgetWatermarkHold
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:64
↓ 1 callersMethodinitContext
(DoFn<IN, OUTDF> function, Collector<WindowedValue<OUTFL>> outCollector)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java:63
↓ 1 callersMethodinitialize
(PipelineOptions options)
runner/src/test/java/com/dataartisans/flink/dataflow/WriteSinkITCase.java:102
↓ 1 callersMethodinitializeStateAndTimers
()
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/StateSerializationTest.java:112
↓ 1 callersMethodinitializeStateForKey
(String key)
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/StateSerializationTest.java:130
↓ 1 callersMethodjoinEvents
(PCollection<String> streamA, PCollection<String> streamB)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/JoinExamples.java:53
↓ 1 callersMethodlistInputDocuments
Lists documents contained beneath the {@code options.input} prefix/directory.
examples/src/main/java/com/dataartisans/flink/dataflow/examples/TFIDF.java:112
↓ 1 callersMethodmakeWindowedValue
(T output, Instant timestamp)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/io/UnboundedSourceWrapper.java:69
↓ 1 callersMethodopenConnection
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/io/UnboundedSocketSource.java:138
↓ 1 callersMethodoutput
(OUT value)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkMultiOutputDoFnFunction.java:141
↓ 1 callersMethodoutputWindowedValue
(OUT output, Instant timestamp, Collection<? extends BoundedWindow> windows, PaneInfo pane)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkDoFnFunction.java:125
↓ 1 callersMethodoutputWithTimestamp
(OUTDF output, Instant timestamp)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java:162
↓ 1 callersMethodoutputWithTimestampHelper
( WindowedValue<IN> inElement, OUTDF output, Instant timestamp, Collector<WindowedValue<OUTFL>> ou
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java:247
↓ 1 callersMethodpane
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkMultiOutputDoFnFunction.java:115
↓ 1 callersMethodprivateGetTypeClass
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/KvCoderTypeInformation.java:76
↓ 1 callersMethodregisterActiveTimer
(K key, TimerInternals.TimerData timer)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java:313
↓ 1 callersMethodresetLocal
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/SerializableFnAggregatorWrapper.java:55
↓ 1 callersMethodrestoreAndTestState
(DataInputView in)
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/StateSerializationTest.java:155
↓ 1 callersMethodrestoreTimerInternals
(StateCheckpointReader reader, KvCoder<K, VIN> kvCoder,
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/AbstractFlinkTimerInternals.java:120
↓ 1 callersMethodrunProgram
(String resultPath)
runner/src/test/java/com/dataartisans/flink/dataflow/WriteSinkITCase.java:65
↓ 1 callersMethodrunProgram
(String resultPath)
runner/src/test/java/com/dataartisans/flink/dataflow/ReadSourceITCase.java:62
↓ 1 callersMethodrunProgram
(String tmpPath, String resultPath)
runner/src/test/java/com/dataartisans/flink/dataflow/AvroITCase.java:62
↓ 1 callersMethodrunProgram
(String resultPath)
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/UnboundedSourceITCase.java:70
↓ 1 callersMethodserialize
(T t, DataOutputView dataOutputView)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/CoderTypeSerializer.java:103
↓ 1 callersMethodsetCurrentInputWatermark
(Instant watermark)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java:423
↓ 1 callersMethodsetCurrentInputWatermarkAfterRecovery
(Instant watermark)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/AbstractFlinkTimerInternals.java:50
↓ 1 callersMethodsetCurrentOutputWatermark
(Instant watermark)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java:427
↓ 1 callersMethodsetCurrentOutputWatermarkAfterRecovery
(Instant watermark)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/AbstractFlinkTimerInternals.java:59
↓ 1 callersMethodsetElement
(KeyedWorkItem<K, VIN> element, FlinkStateInternals<K> stateForKey)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java:417
↓ 1 callersMethodsetElement
(WindowedValue<IN> value)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java:108
↓ 1 callersMethodsetFilesToStage
(List<String> value)
runner/src/main/java/com/dataartisans/flink/dataflow/FlinkPipelineOptions.java:45
↓ 1 callersMethodsetJobName
(String value)
runner/src/main/java/com/dataartisans/flink/dataflow/FlinkPipelineOptions.java:54
↓ 1 callersMethodsetOutputView
(DataOutputView outputView)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/DataOutputViewWrapper.java:39
↓ 1 callersMethodsetSideInputDataSet
(PCollectionView<?> value, DataSet<?> set)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkBatchTranslationContext.java:93
↓ 1 callersMethodsetSlide
(Long value)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/WindowedWordCount.java:94
↓ 1 callersMethodsetWindowSize
(Long value)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/WindowedWordCount.java:88
↓ 1 callersMethodshouldPersist
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:74
↓ 1 callersMethodsideOutput
(TupleTag<T> tag, T output)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java:554
↓ 1 callersMethodsideOutput
(TupleTag<T> tag, T value)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkMultiOutputDoFnFunction.java:153
↓ 1 callersMethodsideOutputWithTimestamp
(TupleTag<T> tag, T output, Instant timestamp)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java:172
↓ 1 callersMethodsideOutputWithTimestampHelper
( WindowedValue<IN> inElement, T output, Instant timestamp, Collector<WindowedValue<OUTFL>> outCol
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java:253
↓ 1 callersMethodsplitIntoBundles
(long desiredShardSizeBytes, PipelineOptions options)
runner/src/test/java/com/dataartisans/flink/dataflow/ReadSourceITCase.java:89
↓ 1 callersMethodstart
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/io/UnboundedSocketSource.java:145
↓ 1 callersMethodstoreState
(AbstractStateBackend.CheckpointStateOutputView out)
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/StateSerializationTest.java:218
↓ 1 callersMethodtimestamp
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkStreamingTransformTranslators.java:253
↓ 1 callersMethodtop
(int candidatesPerPrefix, boolean recursive)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/AutoComplete.java:68
↓ 1 callersMethodtransformTupleTagsToLabels
(TupleTag<?> mainTag, Set<TupleTag<?>> secondaryTags)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkStreamingTransformTranslators.java:385
↓ 1 callersMethodtranslate
(Pipeline pipeline)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkPipelineTranslator.java:31
↓ 1 callersMethodtranslateNode
(Type transform, FlinkStreamingTranslationContext context)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkStreamingPipelineTranslator.java:133
↓ 1 callersMethodtranslateNode
(Type transform, FlinkBatchTranslationContext context)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkBatchPipelineTranslator.java:140
↓ 1 callersMethodunregisterActiveTimer
(K key, TimerInternals.TimerData timer)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java:322
↓ 1 callersMethodvalidate
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/io/UnboundedFlinkSource.java:59
↓ 1 callersMethodwindow
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkDoFnFunction.java:107
↓ 1 callersMethodwindowingInternalsHelper
( WindowedValue<IN> inElement, Collector<WindowedValue<OUTFL>> outCollector)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java:260
↓ 1 callersMethodwithContext
( final Combine.KeyedCombineFn<K, InputT, AccumT, OutputT> combineFn)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:438
↓ 1 callersMethodwithKeyAndContext
( final Combine.CombineFn<InputT, AccumT, OutputT> combineFn)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:463
↓ 1 callersMethodwrite
(int b)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/DataOutputViewWrapper.java:43
MethodAllPrefixes
(int minPrefix)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/AutoComplete.java:232
MethodAvroITCase
()
runner/src/test/java/com/dataartisans/flink/dataflow/AvroITCase.java:35
MethodBound
()
runner/src/main/java/com/dataartisans/flink/dataflow/io/ConsoleIO.java:56
MethodCoderComparator
(Coder<T> coder)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/CoderComparator.java:45
MethodCoderTypeInformation
(Coder<T> coder)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/CoderTypeInformation.java:37
MethodCoderTypeSerializer
(Coder<T> coder)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/CoderTypeSerializer.java:46
MethodCombineFnAggregatorWrapper
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/CombineFnAggregatorWrapper.java:38
MethodCompletionCandidate
(String value, long count)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/AutoComplete.java:257
MethodComputeTfIdf
()
examples/src/main/java/com/dataartisans/flink/dataflow/examples/TFIDF.java:213
MethodComputeTopCompletions
(int candidatesPerPrefix, boolean recursive)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/AutoComplete.java:63
MethodComputeTopFlat
(int candidatesPerPrefix, int minPrefix)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/AutoComplete.java:113
MethodComputeTopRecursive
(int candidatesPerPrefix, int minPrefix)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/AutoComplete.java:155
MethodDataInputViewWrapper
(DataInputView inputView)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/DataInputViewWrapper.java:36
MethodDataOutputViewWrapper
(DataOutputView outputView)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/DataOutputViewWrapper.java:35
MethodDoFnProcessContext
(DoFn<IN, OUTDF> function, Collector<WindowedValue<OUTFL>> outCollector)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java:100
MethodFlinkAbstractParDoWrapper
(PipelineOptions options, WindowingStrategy<?, ?> windowingStrategy, DoFn<IN, OUTDF> doFn)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java:53
MethodFlinkBatchPipelineTranslator
(ExecutionEnvironment env, PipelineOptions options)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkBatchPipelineTranslator.java:51
MethodFlinkBatchTransformTranslators
()
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkBatchTransformTranslators.java:593
MethodFlinkBatchTranslationContext
(ExecutionEnvironment env, PipelineOptions options)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkBatchTranslationContext.java:52
MethodFlinkCoGroupKeyedListAggregator
(CoGbkResultSchema schema, TupleTag<?> tupleTag1, TupleTag<?> tupleTag2)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkCoGroupKeyedListAggregator.java:36
MethodFlinkCreateFunction
(List<byte[]> elements, Coder<OUT> coder)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkCreateFunction.java:38
MethodFlinkDoFnFunction
(DoFn<IN, OUT> doFn, PipelineOptions options)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkDoFnFunction.java:55
MethodFlinkGroupAlsoByWindowWrapper
(PipelineOptions options, CoderRegistry registry,
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java:201
MethodFlinkInMemoryBag
(ByteString stateKey, Coder<T> elemCoder)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:634
MethodFlinkInMemoryKeyedCombiningValue
(ByteString stateKey, Combine.CombineFn<InputT, AccumT, OutputT> co
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:499
MethodFlinkInMemoryValue
(ByteString stateKey, Coder<T> elemCoder)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java:294
MethodFlinkMapperWrapper
(DoFn<KV<KI, VI>, KV<KO, VO>> fn)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/utils/FlinkMapperWrapper.java:22
MethodFlinkMultiOutputDoFnFunction
(DoFn<IN, OUT> doFn, PipelineOptions options, Map<TupleTag<?>, Integer> outputMap)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkMultiOutputDoFnFunction.java:58
MethodFlinkMultiOutputPruningFunction
(int outputTag)
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkMultiOutputPruningFunction.java:30
MethodFlinkParDoBoundMultiWrapper
(PipelineOptions options, WindowingStrategy<?, ?> windowingStrategy, DoFn<IN, OUT> doFn, TupleTag<?> mainTag,
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkParDoBoundMultiWrapper.java:39
← previousnext →201–300 of 813, ranked by callers