Skip navigation links

Back to Flink Website

flink 1.3-SNAPSHOT API

Packages 
Package Description
org.apache.calcite.sql.fun  
org.apache.calcite.sql.validate  
org.apache.calcite.sql2rel  
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.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  
org.apache.flink.api.scala.codegen  
org.apache.flink.api.scala.extensions.impl.acceptPartialFunctions  
org.apache.flink.api.scala.hadoop.mapred  
org.apache.flink.api.scala.hadoop.mapreduce  
org.apache.flink.api.scala.metrics  
org.apache.flink.api.scala.operators  
org.apache.flink.api.scala.typeutils  
org.apache.flink.batch.connectors.cassandra  
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.cep.scala  
org.apache.flink.cep.scala.conditions  
org.apache.flink.cep.scala.pattern  
org.apache.flink.client  
org.apache.flink.client.cli  
org.apache.flink.client.deployment  
org.apache.flink.client.program  
org.apache.flink.configuration  
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.core.testutils  
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.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.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.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.directed  
org.apache.flink.graph.library.clustering.undirected  
org.apache.flink.graph.library.link_analysis  
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.scala  
org.apache.flink.graph.scala.examples  
org.apache.flink.graph.scala.utils  
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.hadoopcompatibility.scala  
org.apache.flink.hcatalog  
org.apache.flink.hcatalog.java  
org.apache.flink.hcatalog.scala  
org.apache.flink.mesos  
org.apache.flink.mesos.cli  
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.ganglia  
org.apache.flink.metrics.graphite  
org.apache.flink.metrics.groups  
org.apache.flink.metrics.jmx  
org.apache.flink.metrics.reporter  
org.apache.flink.metrics.statsd  
org.apache.flink.metrics.util  
org.apache.flink.migration  
org.apache.flink.migration.api.common.state  
org.apache.flink.migration.contrib.streaming.state  
org.apache.flink.migration.runtime.checkpoint  
org.apache.flink.migration.runtime.checkpoint.savepoint  
org.apache.flink.migration.runtime.state  
org.apache.flink.migration.runtime.state.filesystem  
org.apache.flink.migration.runtime.state.memory  
org.apache.flink.migration.state  
org.apache.flink.migration.streaming.api.graph  
org.apache.flink.migration.streaming.runtime.streamrecord  
org.apache.flink.migration.streaming.runtime.tasks  
org.apache.flink.migration.util  
org.apache.flink.ml  
org.apache.flink.ml.classification  
org.apache.flink.ml.common  
org.apache.flink.ml.math  
org.apache.flink.ml.math.distributed  
org.apache.flink.ml.metrics.distances  
org.apache.flink.ml.nn  
org.apache.flink.ml.optimization  
org.apache.flink.ml.outlier  
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.python.api.util  
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.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.impl  
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.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.message  
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.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
This package contains all KvState query related classes.
org.apache.flink.runtime.query.netty
This package contains all Netty-based client/server classes used to query KvState instances.
org.apache.flink.runtime.query.netty.message  
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.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.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.taskexecutor.utils  
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.files  
org.apache.flink.runtime.webmonitor.handlers  
org.apache.flink.runtime.webmonitor.handlers.checkpoints  
org.apache.flink.runtime.webmonitor.history  
org.apache.flink.runtime.webmonitor.metrics  
org.apache.flink.runtime.webmonitor.utils  
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.async  
org.apache.flink.streaming.api.functions.async.collector  
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.scala  
org.apache.flink.streaming.api.scala.async  
org.apache.flink.streaming.api.scala.extensions.impl.acceptPartialFunctions  
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.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.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.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.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.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.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.scala.examples.async  
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.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  
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.api.scala  
org.apache.flink.table.calcite  
org.apache.flink.table.catalog  
org.apache.flink.table.codegen  
org.apache.flink.table.codegen.calls  
org.apache.flink.table.examples.java  
org.apache.flink.table.examples.scala  
org.apache.flink.table.explain  
org.apache.flink.table.expressions  
org.apache.flink.table.functions  
org.apache.flink.table.functions.aggfunctions  
org.apache.flink.table.functions.utils  
org.apache.flink.table.plan  
org.apache.flink.table.plan.cost  
org.apache.flink.table.plan.logical  
org.apache.flink.table.plan.logical.rel  
org.apache.flink.table.plan.nodes  
org.apache.flink.table.plan.nodes.dataset  
org.apache.flink.table.plan.nodes.datastream  
org.apache.flink.table.plan.nodes.logical  
org.apache.flink.table.plan.rules  
org.apache.flink.table.plan.rules.common  
org.apache.flink.table.plan.rules.dataSet  
org.apache.flink.table.plan.rules.datastream  
org.apache.flink.table.plan.rules.logical  
org.apache.flink.table.plan.schema  
org.apache.flink.table.plan.stats  
org.apache.flink.table.plan.util  
org.apache.flink.table.runtime  
org.apache.flink.table.runtime.aggregate  
org.apache.flink.table.runtime.io  
org.apache.flink.table.runtime.triggers  
org.apache.flink.table.runtime.types  
org.apache.flink.table.sinks  
org.apache.flink.table.sources  
org.apache.flink.table.typeutils  
org.apache.flink.table.util  
org.apache.flink.table.validate  
org.apache.flink.test.testdata  
org.apache.flink.test.util  
org.apache.flink.testutils.junit  
org.apache.flink.types  
org.apache.flink.types.parser  
org.apache.flink.util  
org.apache.flink.yarn  
org.apache.flink.yarn.cli  
org.apache.flink.yarn.configuration  
org.apache.flink.yarn.highavailability  
org.apache.flink.yarn.messages  
Skip navigation links

Back to Flink Website

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