Skip navigation links

Back to Flink Website

flink 1.5-SNAPSHOT API

Packages 
Package Description
org.apache.calcite.avatica.util  
org.apache.calcite.rel.rules  
org.apache.calcite.sql2rel  
org.apache.flink.addons.hbase  
org.apache.flink.annotation  
org.apache.flink.annotation.docs  
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.resources  
org.apache.flink.api.common.restartstrategy  
org.apache.flink.api.common.serialization  
org.apache.flink.api.common.state  
org.apache.flink.api.common.time  
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.io.jdbc.split  
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.summarize  
org.apache.flink.api.java.summarize.aggregation  
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.operators  
org.apache.flink.api.scala.typeutils  
org.apache.flink.batch  
org.apache.flink.batch.connectors.cassandra  
org.apache.flink.batch.tests  
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.cep.pattern.conditions  
org.apache.flink.client  
org.apache.flink.client.cli  
org.apache.flink.client.deployment  
org.apache.flink.client.program  
org.apache.flink.client.program.rest  
org.apache.flink.client.program.rest.retry  
org.apache.flink.configuration  
org.apache.flink.contrib.streaming.state  
org.apache.flink.core.fs  
org.apache.flink.core.fs.local  
org.apache.flink.core.io  
org.apache.flink.core.memory  
org.apache.flink.core.testutils  
org.apache.flink.docs.configuration  
org.apache.flink.docs.rest  
org.apache.flink.docs.util  
org.apache.flink.dropwizard  
org.apache.flink.dropwizard.metrics  
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.formats.avro  
org.apache.flink.formats.avro.typeutils  
org.apache.flink.formats.avro.utils  
org.apache.flink.formats.json  
org.apache.flink.fs.openstackhadoop  
org.apache.flink.fs.s3hadoop  
org.apache.flink.fs.s3presto  
org.apache.flink.graph  
org.apache.flink.graph.asm.dataset  
org.apache.flink.graph.asm.degree.annotate
The degree annotation package provides a collection of edge-centric graph algorithms for counting the vertex degree of directed and undirected graphs.
org.apache.flink.graph.asm.degree.annotate.directed  
org.apache.flink.graph.asm.degree.annotate.undirected  
org.apache.flink.graph.asm.degree.filter.undirected  
org.apache.flink.graph.asm.result  
org.apache.flink.graph.asm.simple.directed  
org.apache.flink.graph.asm.simple.undirected  
org.apache.flink.graph.asm.translate  
org.apache.flink.graph.asm.translate.translators  
org.apache.flink.graph.bipartite  
org.apache.flink.graph.drivers  
org.apache.flink.graph.drivers.input  
org.apache.flink.graph.drivers.output  
org.apache.flink.graph.drivers.parameter  
org.apache.flink.graph.drivers.transform  
org.apache.flink.graph.examples  
org.apache.flink.graph.examples.data  
org.apache.flink.graph.generator  
org.apache.flink.graph.generator.random  
org.apache.flink.graph.gsa  
org.apache.flink.graph.library  
org.apache.flink.graph.library.clustering  
org.apache.flink.graph.library.clustering.directed  
org.apache.flink.graph.library.clustering.undirected  
org.apache.flink.graph.library.linkanalysis  
org.apache.flink.graph.library.metric  
org.apache.flink.graph.library.metric.directed  
org.apache.flink.graph.library.metric.undirected  
org.apache.flink.graph.library.similarity  
org.apache.flink.graph.pregel  
org.apache.flink.graph.spargel  
org.apache.flink.graph.types.valuearray  
org.apache.flink.graph.utils  
org.apache.flink.graph.utils.proxy  
org.apache.flink.graph.validation  
org.apache.flink.hadoopcompatibility  
org.apache.flink.hadoopcompatibility.mapred  
org.apache.flink.hadoopcompatibility.mapred.wrapper  
org.apache.flink.hcatalog  
org.apache.flink.hcatalog.java  
org.apache.flink.mesos  
org.apache.flink.mesos.configuration  
org.apache.flink.mesos.entrypoint  
org.apache.flink.mesos.runtime.clusterframework  
org.apache.flink.mesos.runtime.clusterframework.services  
org.apache.flink.mesos.runtime.clusterframework.store  
org.apache.flink.mesos.scheduler  
org.apache.flink.mesos.scheduler.messages  
org.apache.flink.mesos.util  
org.apache.flink.metrics  
org.apache.flink.metrics.datadog  
org.apache.flink.metrics.graphite  
org.apache.flink.metrics.groups  
org.apache.flink.metrics.jmx  
org.apache.flink.metrics.prometheus  
org.apache.flink.metrics.reporter  
org.apache.flink.metrics.slf4j  
org.apache.flink.metrics.statsd  
org.apache.flink.networking  
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.orc  
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.python.api.util  
org.apache.flink.queryablestate  
org.apache.flink.queryablestate.client  
org.apache.flink.queryablestate.client.proxy  
org.apache.flink.queryablestate.client.state  
org.apache.flink.queryablestate.client.state.serialization  
org.apache.flink.queryablestate.exceptions  
org.apache.flink.queryablestate.messages  
org.apache.flink.queryablestate.network  
org.apache.flink.queryablestate.network.messages  
org.apache.flink.queryablestate.network.stats  
org.apache.flink.queryablestate.server  
org.apache.flink.runtime  
org.apache.flink.runtime.accumulators  
org.apache.flink.runtime.akka  
org.apache.flink.runtime.blob  
org.apache.flink.runtime.broadcast  
org.apache.flink.runtime.checkpoint  
org.apache.flink.runtime.checkpoint.decline  
org.apache.flink.runtime.checkpoint.hooks  
org.apache.flink.runtime.checkpoint.savepoint  
org.apache.flink.runtime.client  
org.apache.flink.runtime.clusterframework
This package contains the cluster resource management functionality.
org.apache.flink.runtime.clusterframework.messages
This package contains the actor messages that are sent between the cluster resource framework and the JobManager, as well as the generic messages sent between the cluster resource framework and the client.
org.apache.flink.runtime.clusterframework.overlays  
org.apache.flink.runtime.clusterframework.standalone  
org.apache.flink.runtime.clusterframework.types  
org.apache.flink.runtime.concurrent  
org.apache.flink.runtime.concurrent.akka  
org.apache.flink.runtime.deployment  
org.apache.flink.runtime.dispatcher  
org.apache.flink.runtime.entrypoint  
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.failover  
org.apache.flink.runtime.executiongraph.metrics
This package contains classes implementing various metrics for the job execution, based on the Execution Graph.
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.heartbeat  
org.apache.flink.runtime.highavailability  
org.apache.flink.runtime.highavailability.nonha  
org.apache.flink.runtime.highavailability.nonha.embedded  
org.apache.flink.runtime.highavailability.nonha.leaderelection  
org.apache.flink.runtime.highavailability.nonha.standalone  
org.apache.flink.runtime.highavailability.zookeeper  
org.apache.flink.runtime.history  
org.apache.flink.runtime.instance  
org.apache.flink.runtime.io.async  
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.jobmanager.slots  
org.apache.flink.runtime.jobmaster  
org.apache.flink.runtime.jobmaster.exceptions  
org.apache.flink.runtime.jobmaster.factories  
org.apache.flink.runtime.jobmaster.message  
org.apache.flink.runtime.jobmaster.slotpool  
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.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.metrics  
org.apache.flink.runtime.metrics.dump  
org.apache.flink.runtime.metrics.groups  
org.apache.flink.runtime.metrics.scope  
org.apache.flink.runtime.metrics.util  
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.operators.util.metrics  
org.apache.flink.runtime.plugable  
org.apache.flink.runtime.process  
org.apache.flink.runtime.query  
org.apache.flink.runtime.registration  
org.apache.flink.runtime.resourcemanager  
org.apache.flink.runtime.resourcemanager.exceptions  
org.apache.flink.runtime.resourcemanager.registration  
org.apache.flink.runtime.resourcemanager.slotmanager  
org.apache.flink.runtime.rest  
org.apache.flink.runtime.rest.handler  
org.apache.flink.runtime.rest.handler.async  
org.apache.flink.runtime.rest.handler.cluster  
org.apache.flink.runtime.rest.handler.job  
org.apache.flink.runtime.rest.handler.job.checkpoints  
org.apache.flink.runtime.rest.handler.job.metrics  
org.apache.flink.runtime.rest.handler.job.rescaling  
org.apache.flink.runtime.rest.handler.job.savepoints  
org.apache.flink.runtime.rest.handler.legacy  
org.apache.flink.runtime.rest.handler.legacy.backpressure  
org.apache.flink.runtime.rest.handler.legacy.checkpoints  
org.apache.flink.runtime.rest.handler.legacy.files  
org.apache.flink.runtime.rest.handler.legacy.messages  
org.apache.flink.runtime.rest.handler.legacy.metrics  
org.apache.flink.runtime.rest.handler.taskmanager  
org.apache.flink.runtime.rest.handler.util  
org.apache.flink.runtime.rest.messages  
org.apache.flink.runtime.rest.messages.checkpoints  
org.apache.flink.runtime.rest.messages.cluster  
org.apache.flink.runtime.rest.messages.job  
org.apache.flink.runtime.rest.messages.job.metrics  
org.apache.flink.runtime.rest.messages.job.savepoints  
org.apache.flink.runtime.rest.messages.json  
org.apache.flink.runtime.rest.messages.queue  
org.apache.flink.runtime.rest.messages.taskmanager  
org.apache.flink.runtime.rest.util  
org.apache.flink.runtime.rpc  
org.apache.flink.runtime.rpc.akka  
org.apache.flink.runtime.rpc.akka.exceptions  
org.apache.flink.runtime.rpc.akka.messages  
org.apache.flink.runtime.rpc.exceptions  
org.apache.flink.runtime.rpc.messages  
org.apache.flink.runtime.security  
org.apache.flink.runtime.security.modules  
org.apache.flink.runtime.state  
org.apache.flink.runtime.state.filesystem  
org.apache.flink.runtime.state.heap
This package contains the classes for key/value state backends that store the state on the JVM heap as objects.
org.apache.flink.runtime.state.internal
This package holds the classes of the internal state type hierarchy.
org.apache.flink.runtime.state.memory  
org.apache.flink.runtime.taskexecutor  
org.apache.flink.runtime.taskexecutor.exceptions  
org.apache.flink.runtime.taskexecutor.rpc  
org.apache.flink.runtime.taskexecutor.slot  
org.apache.flink.runtime.taskmanager  
org.apache.flink.runtime.util  
org.apache.flink.runtime.util.clock  
org.apache.flink.runtime.util.event  
org.apache.flink.runtime.webmonitor  
org.apache.flink.runtime.webmonitor.handlers  
org.apache.flink.runtime.webmonitor.handlers.legacy  
org.apache.flink.runtime.webmonitor.handlers.utils  
org.apache.flink.runtime.webmonitor.history  
org.apache.flink.runtime.webmonitor.retriever  
org.apache.flink.runtime.webmonitor.retriever.impl  
org.apache.flink.runtime.webmonitor.utils  
org.apache.flink.runtime.zookeeper  
org.apache.flink.runtime.zookeeper.filesystem  
org.apache.flink.sql.tests  
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.wordcount.util  
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.async  
org.apache.flink.streaming.api.functions.co  
org.apache.flink.streaming.api.functions.query  
org.apache.flink.streaming.api.functions.sink  
org.apache.flink.streaming.api.functions.source  
org.apache.flink.streaming.api.functions.timestamps  
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.async  
org.apache.flink.streaming.api.operators.async.queue  
org.apache.flink.streaming.api.operators.co  
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.cassandra  
org.apache.flink.streaming.connectors.elasticsearch  
org.apache.flink.streaming.connectors.elasticsearch.util  
org.apache.flink.streaming.connectors.elasticsearch2  
org.apache.flink.streaming.connectors.elasticsearch5  
org.apache.flink.streaming.connectors.fs  
org.apache.flink.streaming.connectors.fs.bucketing  
org.apache.flink.streaming.connectors.kafka  
org.apache.flink.streaming.connectors.kafka.config  
org.apache.flink.streaming.connectors.kafka.internal  
org.apache.flink.streaming.connectors.kafka.internal.metrics  
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.nifi  
org.apache.flink.streaming.connectors.rabbitmq  
org.apache.flink.streaming.connectors.rabbitmq.common  
org.apache.flink.streaming.connectors.twitter  
org.apache.flink.streaming.connectors.wikiedits  
org.apache.flink.streaming.examples.async  
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.kafka  
org.apache.flink.streaming.examples.ml  
org.apache.flink.streaming.examples.ml.util  
org.apache.flink.streaming.examples.sideoutput  
org.apache.flink.streaming.examples.socket  
org.apache.flink.streaming.examples.statemachine  
org.apache.flink.streaming.examples.statemachine.dfa  
org.apache.flink.streaming.examples.statemachine.event  
org.apache.flink.streaming.examples.statemachine.generator  
org.apache.flink.streaming.examples.statemachine.kafka  
org.apache.flink.streaming.examples.twitter  
org.apache.flink.streaming.examples.twitter.util  
org.apache.flink.streaming.examples.utils  
org.apache.flink.streaming.examples.windowing  
org.apache.flink.streaming.examples.windowing.util  
org.apache.flink.streaming.examples.wordcount  
org.apache.flink.streaming.examples.wordcount.util  
org.apache.flink.streaming.experimental
This package holds classes that are experimental.
org.apache.flink.streaming.python  
org.apache.flink.streaming.python.api  
org.apache.flink.streaming.python.api.datastream  
org.apache.flink.streaming.python.api.environment  
org.apache.flink.streaming.python.api.functions  
org.apache.flink.streaming.python.util  
org.apache.flink.streaming.python.util.serialization  
org.apache.flink.streaming.runtime.io  
org.apache.flink.streaming.runtime.metrics  
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.functions  
org.apache.flink.streaming.runtime.partitioner  
org.apache.flink.streaming.runtime.streamrecord  
org.apache.flink.streaming.runtime.streamstatus  
org.apache.flink.streaming.runtime.tasks
This package contains classes that realize streaming tasks.
org.apache.flink.streaming.tests  
org.apache.flink.streaming.tests.artificialstate  
org.apache.flink.streaming.tests.artificialstate.builder  
org.apache.flink.streaming.util  
org.apache.flink.streaming.util.functions  
org.apache.flink.streaming.util.keys  
org.apache.flink.streaming.util.serialization  
org.apache.flink.streaming.util.typeutils  
org.apache.flink.table.annotation  
org.apache.flink.table.api.java
Table API (Java)
A BatchTableEnvironment can be used to create a Table from a DataSet.
org.apache.flink.table.client  
org.apache.flink.table.client.cli  
org.apache.flink.table.client.config  
org.apache.flink.table.client.gateway  
org.apache.flink.table.client.gateway.local  
org.apache.flink.table.descriptors  
org.apache.flink.table.examples.java  
org.apache.flink.table.explain  
org.apache.flink.test.testdata  
org.apache.flink.test.util  
org.apache.flink.testutils.category  
org.apache.flink.testutils.junit  
org.apache.flink.types  
org.apache.flink.types.parser  
org.apache.flink.util  
org.apache.flink.util.concurrent  
org.apache.flink.util.function  
org.apache.flink.yarn  
org.apache.flink.yarn.cli  
org.apache.flink.yarn.configuration  
org.apache.flink.yarn.entrypoint  
org.apache.flink.yarn.highavailability  
org.apache.flink.yarn.messages  
org.apache.hadoop.conf  
org.apache.hadoop.util  
org.openjdk.jol.info
This package contains mock classes to avoid a dependency on OpenJDK JOL, which is incompatible with the Apache License.
Skip navigation links

Back to Flink Website

Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.