| 组织ID: |
org.apache.flink |
| 项目ID: |
flink-streaming-java_2.11 |
| 版本: |
0.10.2 |
| 最后修改时间: |
2018-11-16 19:36:25 |
| 包类型: |
java-source (源码) |
| 大小: |
381.63KB |
|
|
| Maven引入代码: |
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.11</artifactId>
<version>0.10.2</version>
<classifier>sources</classifier>
<type>java-source</type>
</dependency>
|
| Gradle引入代码: |
org.apache.flink:flink-streaming-java_2.11:0.10.2
|
| 下载Jar包: |
|
| Jar包内容: |
META-INF/MANIFEST.MF
META-INF/NOTICE
META-INF/LICENSE
META-INF/DEPENDENCIES
org/apache/flink/streaming/api/watermark/Watermark.java
org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
org/apache/flink/streaming/api/operators/StreamFilter.java
org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
org/apache/flink/streaming/api/operators/StreamGroupedReduce.java
org/apache/flink/streaming/api/operators/StreamSink.java
org/apache/flink/streaming/api/operators/StreamCounter.java
org/apache/flink/streaming/api/operators/OneInputStreamOperator.java
org/apache/flink/streaming/api/operators/StreamSource.java
org/apache/flink/streaming/api/operators/ChainingStrategy.java
org/apache/flink/streaming/api/operators/StreamOperator.java
org/apache/flink/streaming/api/operators/StreamMap.java
org/apache/flink/streaming/api/operators/TwoInputStreamOperator.java
org/apache/flink/streaming/api/operators/StreamProject.java
org/apache/flink/streaming/api/operators/StreamFlatMap.java
org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java
org/apache/flink/streaming/api/operators/co/CoStreamMap.java
org/apache/flink/streaming/api/operators/co/CoStreamFlatMap.java
org/apache/flink/streaming/api/operators/TimestampedCollector.java
org/apache/flink/streaming/api/operators/Output.java
org/apache/flink/streaming/api/operators/StreamGroupedFold.java
org/apache/flink/streaming/api/operators/OutputTypeConfigurable.java
org/apache/flink/streaming/api/TimeCharacteristic.java
org/apache/flink/streaming/api/windowing/time/ProcessingTime.java
org/apache/flink/streaming/api/windowing/time/AbstractTime.java
org/apache/flink/streaming/api/windowing/time/EventTime.java
org/apache/flink/streaming/api/windowing/time/Time.java
org/apache/flink/streaming/api/windowing/triggers/ProcessingTimeTrigger.java
org/apache/flink/streaming/api/windowing/triggers/ContinuousProcessingTimeTrigger.java
org/apache/flink/streaming/api/windowing/triggers/EventTimeTrigger.java
org/apache/flink/streaming/api/windowing/triggers/Trigger.java
org/apache/flink/streaming/api/windowing/triggers/CountTrigger.java
org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java
org/apache/flink/streaming/api/windowing/triggers/DeltaTrigger.java
org/apache/flink/streaming/api/windowing/triggers/PurgingTrigger.java
org/apache/flink/streaming/api/windowing/evictors/TimeEvictor.java
org/apache/flink/streaming/api/windowing/evictors/Evictor.java
org/apache/flink/streaming/api/windowing/evictors/CountEvictor.java
org/apache/flink/streaming/api/windowing/evictors/DeltaEvictor.java
org/apache/flink/streaming/api/windowing/assigners/WindowAssigner.java
org/apache/flink/streaming/api/windowing/assigners/SlidingTimeWindows.java
org/apache/flink/streaming/api/windowing/assigners/GlobalWindows.java
org/apache/flink/streaming/api/windowing/assigners/TumblingTimeWindows.java
org/apache/flink/streaming/api/windowing/windows/GlobalWindow.java
org/apache/flink/streaming/api/windowing/windows/Window.java
org/apache/flink/streaming/api/windowing/windows/TimeWindow.java
org/apache/flink/streaming/api/environment/StreamExecutionEnvironmentFactory.java
org/apache/flink/streaming/api/environment/StreamPlanEnvironment.java
org/apache/flink/streaming/api/environment/StreamContextEnvironment.java
org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java
org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java
org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
org/apache/flink/streaming/api/graph/StreamNode.java
org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
org/apache/flink/streaming/api/graph/JSONGenerator.java
org/apache/flink/streaming/api/graph/StreamConfig.java
org/apache/flink/streaming/api/graph/StreamGraph.java
org/apache/flink/streaming/api/graph/StreamEdge.java
org/apache/flink/streaming/api/graph/StreamGraphGenerator.java
org/apache/flink/streaming/api/checkpoint/CheckpointNotifier.java
org/apache/flink/streaming/api/checkpoint/Checkpointed.java
org/apache/flink/streaming/api/checkpoint/CheckpointedAsynchronously.java
org/apache/flink/streaming/api/datastream/AllWindowedStream.java
org/apache/flink/streaming/api/datastream/CoGroupedStreams.java
org/apache/flink/streaming/api/datastream/KeyedStream.java
org/apache/flink/streaming/api/datastream/JoinedStreams.java
org/apache/flink/streaming/api/datastream/StreamProjection.java
org/apache/flink/streaming/api/datastream/IterativeStream.java
org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java
org/apache/flink/streaming/api/datastream/DataStreamSink.java
org/apache/flink/streaming/api/datastream/DataStream.java
org/apache/flink/streaming/api/datastream/DataStreamSource.java
org/apache/flink/streaming/api/datastream/SplitStream.java
org/apache/flink/streaming/api/datastream/WindowedStream.java
org/apache/flink/streaming/api/datastream/ConnectedStreams.java
org/apache/flink/streaming/api/functions/TimestampExtractor.java
org/apache/flink/streaming/api/functions/windowing/ReduceWindowFunctionWithWindow.java
org/apache/flink/streaming/api/functions/windowing/ReduceAllWindowFunction.java
org/apache/flink/streaming/api/functions/windowing/delta/CosineDistance.java
org/apache/flink/streaming/api/functions/windowing/delta/DeltaFunction.java
org/apache/flink/streaming/api/functions/windowing/delta/ExtractionAwareDeltaFunction.java
org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromArray.java
org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromTuple.java
org/apache/flink/streaming/api/functions/windowing/delta/extractor/ConcatenatedExtract.java
org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromArray.java
org/apache/flink/streaming/api/functions/windowing/delta/extractor/Extractor.java
org/apache/flink/streaming/api/functions/windowing/delta/extractor/ArrayFromTuple.java
org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromTuple.java
org/apache/flink/streaming/api/functions/windowing/delta/EuclideanDistance.java
org/apache/flink/streaming/api/functions/windowing/FoldAllWindowFunction.java
org/apache/flink/streaming/api/functions/windowing/WindowFunction.java
org/apache/flink/streaming/api/functions/windowing/FoldWindowFunction.java
org/apache/flink/streaming/api/functions/windowing/AllWindowFunction.java
org/apache/flink/streaming/api/functions/windowing/ReduceWindowFunction.java
org/apache/flink/streaming/api/functions/windowing/RichAllWindowFunction.java
org/apache/flink/streaming/api/functions/windowing/RichWindowFunction.java
org/apache/flink/streaming/api/functions/AscendingTimestampExtractor.java
org/apache/flink/streaming/api/functions/sink/WriteFormatAsText.java
org/apache/flink/streaming/api/functions/sink/RichSinkFunction.java
org/apache/flink/streaming/api/functions/sink/WriteFormatAsCsv.java
org/apache/flink/streaming/api/functions/sink/FileSinkFunction.java
org/apache/flink/streaming/api/functions/sink/SinkFunction.java
org/apache/flink/streaming/api/functions/sink/FileSinkFunctionByMillis.java
org/apache/flink/streaming/api/functions/sink/WriteFormat.java
org/apache/flink/streaming/api/functions/sink/SocketClientSink.java
org/apache/flink/streaming/api/functions/sink/WriteSinkFunction.java
org/apache/flink/streaming/api/functions/sink/WriteSinkFunctionByMillis.java
org/apache/flink/streaming/api/functions/sink/PrintSinkFunction.java
org/apache/flink/streaming/api/functions/aggregation/AggregationFunction.java
org/apache/flink/streaming/api/functions/aggregation/Comparator.java
org/apache/flink/streaming/api/functions/aggregation/SumFunction.java
org/apache/flink/streaming/api/functions/aggregation/ComparableAggregator.java
org/apache/flink/streaming/api/functions/aggregation/SumAggregator.java
org/apache/flink/streaming/api/functions/co/CoFlatMapFunction.java
org/apache/flink/streaming/api/functions/co/CoMapFunction.java
org/apache/flink/streaming/api/functions/co/RichCoFlatMapFunction.java
org/apache/flink/streaming/api/functions/co/RichCoMapFunction.java
org/apache/flink/streaming/api/functions/source/FromIteratorFunction.java
org/apache/flink/streaming/api/functions/source/RichSourceFunction.java
org/apache/flink/streaming/api/functions/source/ConnectorSource.java
org/apache/flink/streaming/api/functions/source/MessageAcknowledingSourceBase.java
org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java
org/apache/flink/streaming/api/functions/source/FileReadFunction.java
org/apache/flink/streaming/api/functions/source/FileMonitoringFunction.java
org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
org/apache/flink/streaming/api/functions/source/RichEventTimeSourceFunction.java
org/apache/flink/streaming/api/functions/source/RichParallelSourceFunction.java
org/apache/flink/streaming/api/functions/source/SourceFunction.java
org/apache/flink/streaming/api/functions/source/ParallelSourceFunction.java
org/apache/flink/streaming/api/functions/source/FromElementsFunction.java
org/apache/flink/streaming/api/functions/source/FileSourceFunction.java
org/apache/flink/streaming/api/functions/source/EventTimeSourceFunction.java
org/apache/flink/streaming/api/functions/source/FromSplittableIteratorFunction.java
org/apache/flink/streaming/api/CheckpointingMode.java
org/apache/flink/streaming/api/collector/selector/OutputSelectorWrapperFactory.java
org/apache/flink/streaming/api/collector/selector/DirectedOutputSelectorWrapper.java
org/apache/flink/streaming/api/collector/selector/OutputSelector.java
org/apache/flink/streaming/api/collector/selector/BroadcastOutputSelectorWrapper.java
org/apache/flink/streaming/api/collector/selector/OutputSelectorWrapper.java
org/apache/flink/streaming/api/transformations/SplitTransformation.java
org/apache/flink/streaming/api/transformations/PartitionTransformation.java
org/apache/flink/streaming/api/transformations/FeedbackTransformation.java
org/apache/flink/streaming/api/transformations/SourceTransformation.java
org/apache/flink/streaming/api/transformations/CoFeedbackTransformation.java
org/apache/flink/streaming/api/transformations/SelectTransformation.java
org/apache/flink/streaming/api/transformations/TwoInputTransformation.java
org/apache/flink/streaming/api/transformations/UnionTransformation.java
org/apache/flink/streaming/api/transformations/OneInputTransformation.java
org/apache/flink/streaming/api/transformations/StreamTransformation.java
org/apache/flink/streaming/api/transformations/SinkTransformation.java
org/apache/flink/streaming/util/serialization/TypeInformationSerializationSchema.java
org/apache/flink/streaming/util/serialization/SimpleStringSchema.java
org/apache/flink/streaming/util/serialization/SerializationSchema.java
org/apache/flink/streaming/util/serialization/RawSchema.java
org/apache/flink/streaming/util/serialization/DeserializationSchema.java
org/apache/flink/streaming/util/serialization/JavaDefaultStringSchema.java
org/apache/flink/streaming/util/FieldAccessor.java
org/apache/flink/streaming/util/keys/KeySelectorUtil.java
org/apache/flink/streaming/runtime/operators/ExtractTimestampsOperator.java
org/apache/flink/streaming/runtime/operators/windowing/buffers/EvictingWindowBuffer.java
org/apache/flink/streaming/runtime/operators/windowing/buffers/PreAggregatingHeapWindowBuffer.java
org/apache/flink/streaming/runtime/operators/windowing/buffers/HeapWindowBuffer.java
org/apache/flink/streaming/runtime/operators/windowing/buffers/WindowBuffer.java
org/apache/flink/streaming/runtime/operators/windowing/buffers/WindowBufferFactory.java
org/apache/flink/streaming/runtime/operators/windowing/AbstractKeyedTimePanes.java
org/apache/flink/streaming/runtime/operators/windowing/AccumulatingProcessingTimeWindowOperator.java
org/apache/flink/streaming/runtime/operators/windowing/AggregatingKeyedTimePanes.java
org/apache/flink/streaming/runtime/operators/windowing/EvictingNonKeyedWindowOperator.java
org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
org/apache/flink/streaming/runtime/operators/windowing/AggregatingProcessingTimeWindowOperator.java
org/apache/flink/streaming/runtime/operators/windowing/package-info.java
org/apache/flink/streaming/runtime/operators/windowing/EvictingWindowOperator.java
#内容未全部加载，请点击展开加载全部代码(NowJava.com)
|
| 依赖Jar: |
无
|
查看flink-streaming-java_2.11所有版本文件