| org.apache.flink.addons.hbase |
|
| org.apache.flink.annotation |
|
| org.apache.flink.api.avro |
|
| org.apache.flink.api.common |
|
| org.apache.flink.api.common.accumulators |
|
| org.apache.flink.api.common.aggregators |
|
| org.apache.flink.api.common.cache |
|
| org.apache.flink.api.common.distributions |
|
| org.apache.flink.api.common.functions |
|
| org.apache.flink.api.common.functions.util |
|
| org.apache.flink.api.common.io |
|
| org.apache.flink.api.common.io.compression |
|
| org.apache.flink.api.common.io.statistics |
|
| org.apache.flink.api.common.operators |
|
| org.apache.flink.api.common.operators.base |
|
| org.apache.flink.api.common.operators.util |
|
| org.apache.flink.api.common.restartstrategy |
|
| org.apache.flink.api.common.state |
|
| org.apache.flink.api.common.typeinfo |
|
| org.apache.flink.api.common.typeutils |
|
| org.apache.flink.api.common.typeutils.base |
|
| org.apache.flink.api.common.typeutils.base.array |
|
| org.apache.flink.api.java |
|
| org.apache.flink.api.java.aggregation |
|
| org.apache.flink.api.java.functions |
|
| org.apache.flink.api.java.hadoop.common |
|
| org.apache.flink.api.java.hadoop.mapred |
|
| org.apache.flink.api.java.hadoop.mapred.utils |
|
| org.apache.flink.api.java.hadoop.mapred.wrapper |
|
| org.apache.flink.api.java.hadoop.mapreduce |
|
| org.apache.flink.api.java.hadoop.mapreduce.utils |
|
| org.apache.flink.api.java.hadoop.mapreduce.wrapper |
|
| org.apache.flink.api.java.io |
|
| org.apache.flink.api.java.io.jdbc |
|
| org.apache.flink.api.java.operators |
|
| org.apache.flink.api.java.operators.join |
|
| org.apache.flink.api.java.operators.translation |
|
| org.apache.flink.api.java.sampling |
|
| org.apache.flink.api.java.sca |
|
| org.apache.flink.api.java.table |
|
| org.apache.flink.api.java.tuple |
|
| org.apache.flink.api.java.tuple.builder |
|
| org.apache.flink.api.java.typeutils |
|
| org.apache.flink.api.java.typeutils.runtime |
|
| org.apache.flink.api.java.typeutils.runtime.kryo |
|
| org.apache.flink.api.java.utils |
|
| org.apache.flink.api.scala |
|
| org.apache.flink.api.scala.codegen |
|
| org.apache.flink.api.scala.hadoop.mapred |
|
| org.apache.flink.api.scala.hadoop.mapreduce |
|
| org.apache.flink.api.scala.operators |
|
| org.apache.flink.api.scala.table |
|
| org.apache.flink.api.scala.typeutils |
|
| org.apache.flink.api.table |
Table API
This package contains the generic part of the Table API.
|
| org.apache.flink.api.table.codegen |
|
| org.apache.flink.api.table.explain |
|
| org.apache.flink.api.table.expressions |
|
| org.apache.flink.api.table.expressions.analysis |
|
| org.apache.flink.api.table.parser |
|
| org.apache.flink.api.table.plan |
|
| org.apache.flink.api.table.runtime |
|
| org.apache.flink.api.table.trees |
|
| org.apache.flink.api.table.typeinfo |
|
| org.apache.flink.cep |
|
| org.apache.flink.cep.nfa |
|
| org.apache.flink.cep.nfa.compiler |
|
| org.apache.flink.cep.operator |
|
| org.apache.flink.cep.pattern |
|
| org.apache.flink.client |
|
| org.apache.flink.client.cli |
|
| org.apache.flink.client.program |
|
| org.apache.flink.configuration |
|
| org.apache.flink.contrib.operatorstatistics |
|
| org.apache.flink.contrib.operatorstatistics.heavyhitters |
|
| org.apache.flink.contrib.streaming |
|
| org.apache.flink.contrib.streaming.state |
|
| org.apache.flink.contrib.tweetinputformat.io |
|
| org.apache.flink.contrib.tweetinputformat.model.places |
|
| org.apache.flink.contrib.tweetinputformat.model.tweet |
|
| org.apache.flink.contrib.tweetinputformat.model.tweet.entities |
|
| org.apache.flink.contrib.tweetinputformat.model.User |
|
| org.apache.flink.core.fs |
|
| org.apache.flink.core.fs.local |
|
| org.apache.flink.core.io |
|
| org.apache.flink.core.memory |
|
| org.apache.flink.examples.java |
|
| org.apache.flink.examples.java.clustering |
|
| org.apache.flink.examples.java.clustering.util |
|
| org.apache.flink.examples.java.distcp |
|
| org.apache.flink.examples.java.graph |
|
| org.apache.flink.examples.java.graph.util |
|
| org.apache.flink.examples.java.misc |
|
| org.apache.flink.examples.java.ml |
|
| org.apache.flink.examples.java.ml.util |
|
| org.apache.flink.examples.java.relational |
|
| org.apache.flink.examples.java.relational.util |
|
| org.apache.flink.examples.java.wordcount |
|
| org.apache.flink.examples.java.wordcount.util |
|
| org.apache.flink.examples.java8.relational |
|
| org.apache.flink.examples.java8.wordcount |
|
| org.apache.flink.examples.scala |
|
| org.apache.flink.examples.scala.clustering |
|
| org.apache.flink.examples.scala.graph |
|
| org.apache.flink.examples.scala.misc |
|
| org.apache.flink.examples.scala.ml |
|
| org.apache.flink.examples.scala.relational |
|
| org.apache.flink.examples.scala.wordcount |
|
| org.apache.flink.graph |
|
| org.apache.flink.graph.examples |
|
| org.apache.flink.graph.examples.data |
|
| org.apache.flink.graph.examples.utils |
|
| org.apache.flink.graph.gsa |
|
| org.apache.flink.graph.library |
|
| org.apache.flink.graph.scala |
|
| org.apache.flink.graph.scala.examples |
|
| org.apache.flink.graph.scala.utils |
|
| org.apache.flink.graph.spargel |
|
| org.apache.flink.graph.utils |
|
| org.apache.flink.graph.validation |
|
| org.apache.flink.hadoopcompatibility.mapred |
|
| org.apache.flink.hadoopcompatibility.mapred.wrapper |
|
| org.apache.flink.hcatalog |
|
| org.apache.flink.hcatalog.java |
|
| org.apache.flink.hcatalog.scala |
|
| org.apache.flink.ml |
|
| org.apache.flink.ml.classification |
|
| org.apache.flink.ml.common |
|
| org.apache.flink.ml.math |
|
| org.apache.flink.ml.metrics.distances |
|
| org.apache.flink.ml.optimization |
|
| org.apache.flink.ml.pipeline |
|
| org.apache.flink.ml.preprocessing |
|
| org.apache.flink.ml.recommendation |
|
| org.apache.flink.ml.regression |
|
| org.apache.flink.optimizer |
|
| org.apache.flink.optimizer.costs |
|
| org.apache.flink.optimizer.dag |
|
| org.apache.flink.optimizer.dataproperties |
|
| org.apache.flink.optimizer.operators |
|
| org.apache.flink.optimizer.plan |
|
| org.apache.flink.optimizer.plandump |
|
| org.apache.flink.optimizer.plantranslate |
|
| org.apache.flink.optimizer.postpass |
|
| org.apache.flink.optimizer.traversals |
This package contains the various traversals over the program plan and the
optimizer DAG (directed acyclic graph) that are made in the course of
the optimization.
|
| org.apache.flink.optimizer.util |
|
| org.apache.flink.python.api |
|
| org.apache.flink.python.api.functions |
|
| org.apache.flink.python.api.functions.util |
|
| org.apache.flink.python.api.streaming.data |
|
| org.apache.flink.python.api.streaming.plan |
|
| org.apache.flink.python.api.streaming.util |
|
| org.apache.flink.python.api.types |
|
| org.apache.flink.runtime |
|
| org.apache.flink.runtime.accumulators |
|
| org.apache.flink.runtime.akka |
|
| org.apache.flink.runtime.akka.serialization |
|
| org.apache.flink.runtime.blob |
|
| org.apache.flink.runtime.broadcast |
|
| org.apache.flink.runtime.checkpoint |
|
| org.apache.flink.runtime.checkpoint.stats |
|
| org.apache.flink.runtime.client |
|
| org.apache.flink.runtime.deployment |
|
| org.apache.flink.runtime.event |
|
| org.apache.flink.runtime.execution |
|
| org.apache.flink.runtime.execution.librarycache |
|
| org.apache.flink.runtime.executiongraph |
|
| org.apache.flink.runtime.executiongraph.restart |
|
| org.apache.flink.runtime.filecache |
|
| org.apache.flink.runtime.fs.hdfs |
|
| org.apache.flink.runtime.fs.maprfs |
|
| org.apache.flink.runtime.instance |
|
| org.apache.flink.runtime.io.disk |
|
| org.apache.flink.runtime.io.disk.iomanager |
|
| org.apache.flink.runtime.io.network |
|
| org.apache.flink.runtime.io.network.api |
|
| org.apache.flink.runtime.io.network.api.reader |
|
| org.apache.flink.runtime.io.network.api.serialization |
|
| org.apache.flink.runtime.io.network.api.writer |
|
| org.apache.flink.runtime.io.network.buffer |
|
| org.apache.flink.runtime.io.network.netty |
|
| org.apache.flink.runtime.io.network.netty.exception |
|
| org.apache.flink.runtime.io.network.partition |
|
| org.apache.flink.runtime.io.network.partition.consumer |
|
| org.apache.flink.runtime.iterative.concurrent |
|
| org.apache.flink.runtime.iterative.convergence |
|
| org.apache.flink.runtime.iterative.event |
|
| org.apache.flink.runtime.iterative.io |
|
| org.apache.flink.runtime.iterative.task |
|
| org.apache.flink.runtime.jobgraph |
|
| org.apache.flink.runtime.jobgraph.jsonplan |
|
| org.apache.flink.runtime.jobgraph.tasks |
|
| org.apache.flink.runtime.jobmanager |
|
| org.apache.flink.runtime.jobmanager.scheduler |
|
| org.apache.flink.runtime.leaderelection |
|
| org.apache.flink.runtime.leaderretrieval |
|
| org.apache.flink.runtime.memory |
|
| org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
| org.apache.flink.runtime.messages.accumulators |
|
| org.apache.flink.runtime.messages.checkpoint |
This package contains the messages that are sent between JobManager
and TaskManager to coordinate the checkpoint snapshots of the
distributed dataflow. |
| org.apache.flink.runtime.messages.webmonitor |
This package contains the actor messages that are sent between the
JobManager and components that are interested in the status of
the JobManager.
|
| org.apache.flink.runtime.minicluster |
|
| org.apache.flink.runtime.net |
|
| org.apache.flink.runtime.operators |
|
| org.apache.flink.runtime.operators.chaining |
|
| org.apache.flink.runtime.operators.hash |
|
| org.apache.flink.runtime.operators.resettable |
|
| org.apache.flink.runtime.operators.shipping |
|
| org.apache.flink.runtime.operators.sort |
|
| org.apache.flink.runtime.operators.udf |
|
| org.apache.flink.runtime.operators.util |
|
| org.apache.flink.runtime.plugable |
|
| org.apache.flink.runtime.process |
|
| org.apache.flink.runtime.security |
|
| org.apache.flink.runtime.state |
|
| org.apache.flink.runtime.state.filesystem |
|
| org.apache.flink.runtime.state.memory |
|
| org.apache.flink.runtime.taskmanager |
|
| org.apache.flink.runtime.util |
|
| org.apache.flink.runtime.util.event |
|
| org.apache.flink.runtime.webmonitor |
|
| org.apache.flink.runtime.webmonitor.files |
|
| org.apache.flink.runtime.webmonitor.handlers |
|
| org.apache.flink.runtime.yarn |
|
| org.apache.flink.runtime.zookeeper |
|
| org.apache.flink.runtime.zookeeper.filesystem |
|
| org.apache.flink.storm.api |
|
| org.apache.flink.storm.exclamation |
|
| org.apache.flink.storm.exclamation.operators |
|
| org.apache.flink.storm.join |
|
| org.apache.flink.storm.print |
|
| org.apache.flink.storm.split |
|
| org.apache.flink.storm.split.operators |
|
| org.apache.flink.storm.util |
|
| org.apache.flink.storm.wordcount |
|
| org.apache.flink.storm.wordcount.operators |
|
| org.apache.flink.storm.wrappers |
|
| org.apache.flink.streaming.api |
|
| org.apache.flink.streaming.api.checkpoint |
|
| org.apache.flink.streaming.api.collector.selector |
|
| org.apache.flink.streaming.api.datastream |
|
| org.apache.flink.streaming.api.environment |
|
| org.apache.flink.streaming.api.functions |
|
| org.apache.flink.streaming.api.functions.aggregation |
|
| org.apache.flink.streaming.api.functions.co |
|
| org.apache.flink.streaming.api.functions.sink |
|
| org.apache.flink.streaming.api.functions.source |
|
| org.apache.flink.streaming.api.functions.windowing |
|
| org.apache.flink.streaming.api.functions.windowing.delta |
|
| org.apache.flink.streaming.api.functions.windowing.delta.extractor |
|
| org.apache.flink.streaming.api.graph |
|
| org.apache.flink.streaming.api.operators |
|
| org.apache.flink.streaming.api.operators.co |
|
| org.apache.flink.streaming.api.scala |
|
| org.apache.flink.streaming.api.scala.function |
|
| org.apache.flink.streaming.api.scala.function.util |
|
| org.apache.flink.streaming.api.transformations |
|
| org.apache.flink.streaming.api.watermark |
|
| org.apache.flink.streaming.api.windowing.assigners |
|
| org.apache.flink.streaming.api.windowing.evictors |
|
| org.apache.flink.streaming.api.windowing.time |
|
| org.apache.flink.streaming.api.windowing.triggers |
|
| org.apache.flink.streaming.api.windowing.windows |
|
| org.apache.flink.streaming.connectors.elasticsearch |
|
| org.apache.flink.streaming.connectors.flume |
|
| org.apache.flink.streaming.connectors.fs |
|
| org.apache.flink.streaming.connectors.json |
|
| org.apache.flink.streaming.connectors.kafka |
|
| org.apache.flink.streaming.connectors.kafka.internals |
|
| org.apache.flink.streaming.connectors.kafka.internals.metrics |
|
| org.apache.flink.streaming.connectors.kafka.partitioner |
|
| org.apache.flink.streaming.connectors.kafka.util |
|
| org.apache.flink.streaming.connectors.nifi |
|
| org.apache.flink.streaming.connectors.rabbitmq |
|
| org.apache.flink.streaming.connectors.twitter |
|
| org.apache.flink.streaming.connectors.wikiedits |
|
| org.apache.flink.streaming.examples.iteration |
|
| org.apache.flink.streaming.examples.iteration.util |
|
| org.apache.flink.streaming.examples.java8.wordcount |
|
| org.apache.flink.streaming.examples.join |
|
| org.apache.flink.streaming.examples.join.util |
|
| org.apache.flink.streaming.examples.kafka |
|
| org.apache.flink.streaming.examples.ml |
|
| org.apache.flink.streaming.examples.ml.util |
|
| org.apache.flink.streaming.examples.socket |
|
| org.apache.flink.streaming.examples.twitter |
|
| org.apache.flink.streaming.examples.twitter.util |
|
| org.apache.flink.streaming.examples.windowing |
|
| org.apache.flink.streaming.examples.windowing.util |
|
| org.apache.flink.streaming.examples.wordcount |
|
| org.apache.flink.streaming.runtime.io |
|
| org.apache.flink.streaming.runtime.operators |
This package contains the operators that perform the stream transformations.
|
| org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
| org.apache.flink.streaming.runtime.operators.windowing.buffers |
|
| org.apache.flink.streaming.runtime.operators.windowing.functions |
|
| org.apache.flink.streaming.runtime.partitioner |
|
| org.apache.flink.streaming.runtime.streamrecord |
|
| org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
| org.apache.flink.streaming.scala.examples.join |
|
| org.apache.flink.streaming.scala.examples.socket |
|
| org.apache.flink.streaming.scala.examples.windowing |
|
| org.apache.flink.streaming.util |
|
| org.apache.flink.streaming.util.keys |
|
| org.apache.flink.streaming.util.serialization |
|
| org.apache.flink.test.testdata |
|
| org.apache.flink.test.util |
|
| org.apache.flink.types |
|
| org.apache.flink.types.parser |
|
| org.apache.flink.util |
|
| org.apache.flink.yarn |
|