Skip navigation links

Back to Flink Website

flink 1.10-SNAPSHOT API

Packages 
Package Description
example.avro  
org.apache.calcite.avatica.util  
org.apache.calcite.jdbc  
org.apache.calcite.plan  
org.apache.calcite.sql
This package is needed because the constructor of SqlTypeNameSpec is package scope, we should merge this package into org.apache.flink.sql.parser.type when CALCITE-3360 is resolved.
org.apache.calcite.sql.validate  
org.apache.calcite.sql2rel  
org.apache.flink.addons.hbase  
org.apache.flink.addons.hbase.util  
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.ratelimiting  
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.python  
org.apache.flink.api.common.python.pickle  
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.dag  
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.dialect  
org.apache.flink.api.java.io.jdbc.split  
org.apache.flink.api.java.io.jdbc.writer  
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.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.avro.generated  
org.apache.flink.batch  
org.apache.flink.batch.connectors.cassandra  
org.apache.flink.batch.tests  
org.apache.flink.batch.tests.util  
org.apache.flink.cep  
org.apache.flink.cep.functions  
org.apache.flink.cep.functions.adaptors  
org.apache.flink.cep.nfa  
org.apache.flink.cep.nfa.aftermatch  
org.apache.flink.cep.nfa.compiler  
org.apache.flink.cep.nfa.sharedbuffer  
org.apache.flink.cep.operator  
org.apache.flink.cep.pattern  
org.apache.flink.cep.pattern.conditions  
org.apache.flink.cep.time  
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.client.python  
org.apache.flink.configuration  
org.apache.flink.configuration.description  
org.apache.flink.connectors.hive  
org.apache.flink.container.entrypoint  
org.apache.flink.contrib.streaming.state  
org.apache.flink.contrib.streaming.state.iterator  
org.apache.flink.contrib.streaming.state.restore  
org.apache.flink.contrib.streaming.state.snapshot  
org.apache.flink.contrib.streaming.state.ttl  
org.apache.flink.core.execution  
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.plugin  
org.apache.flink.core.testutils  
org.apache.flink.deployment  
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.fnexecution.v1  
org.apache.flink.formats.avro  
org.apache.flink.formats.avro.registry.confluent  
org.apache.flink.formats.avro.typeutils  
org.apache.flink.formats.avro.utils  
org.apache.flink.formats.csv  
org.apache.flink.formats.json  
org.apache.flink.formats.parquet  
org.apache.flink.formats.parquet.avro  
org.apache.flink.formats.parquet.utils  
org.apache.flink.formats.sequencefile  
org.apache.flink.fs.anotherdummy  
org.apache.flink.fs.azurefs  
org.apache.flink.fs.dummy  
org.apache.flink.fs.openstackhadoop  
org.apache.flink.fs.osshadoop  
org.apache.flink.fs.s3.common  
org.apache.flink.fs.s3.common.utils  
org.apache.flink.fs.s3.common.writer  
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.influxdb  
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.ml.api.core  
org.apache.flink.ml.api.misc.param  
org.apache.flink.ml.common  
org.apache.flink.ml.common.linalg  
org.apache.flink.ml.common.mapper  
org.apache.flink.ml.common.model  
org.apache.flink.ml.common.statistics.basicstatistic  
org.apache.flink.ml.common.utils  
org.apache.flink.ml.operator  
org.apache.flink.ml.operator.batch  
org.apache.flink.ml.operator.batch.source  
org.apache.flink.ml.operator.stream  
org.apache.flink.ml.operator.stream.source  
org.apache.flink.ml.params.shared  
org.apache.flink.ml.params.shared.colname  
org.apache.flink.ml.pipeline  
org.apache.flink.ml.util.param  
org.apache.flink.mock  
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  
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.quickstarts.test  
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.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.overlays  
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.dispatcher.runner  
org.apache.flink.runtime.entrypoint  
org.apache.flink.runtime.entrypoint.component  
org.apache.flink.runtime.entrypoint.parser  
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.failover.flip1  
org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease  
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.standalone  
org.apache.flink.runtime.highavailability.zookeeper  
org.apache.flink.runtime.history  
org.apache.flink.runtime.instance  
org.apache.flink.runtime.io  
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.metrics  
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.jobgraph.topology  
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.factories  
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 Flink's distributed components to coordinate the distributed operations.
org.apache.flink.runtime.messages.checkpoint
This package contains the messages that are sent between JobMaster and TaskExecutor 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.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.files  
org.apache.flink.runtime.rest.handler.legacy.messages  
org.apache.flink.runtime.rest.handler.legacy.metrics  
org.apache.flink.runtime.rest.handler.router  
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.job.savepoints.stop  
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.rest.versioning  
org.apache.flink.runtime.rpc  
org.apache.flink.runtime.rpc.akka  
org.apache.flink.runtime.rpc.akka.exceptions  
org.apache.flink.runtime.rpc.exceptions  
org.apache.flink.runtime.rpc.messages  
org.apache.flink.runtime.scheduler  
org.apache.flink.runtime.scheduler.adapter  
org.apache.flink.runtime.scheduler.strategy  
org.apache.flink.runtime.security  
org.apache.flink.runtime.security.modules  
org.apache.flink.runtime.shuffle  
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.heap.space  
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.state.metainfo  
org.apache.flink.runtime.state.ttl  
org.apache.flink.runtime.taskexecutor  
org.apache.flink.runtime.taskexecutor.exceptions  
org.apache.flink.runtime.taskexecutor.partition  
org.apache.flink.runtime.taskexecutor.rpc  
org.apache.flink.runtime.taskexecutor.slot  
org.apache.flink.runtime.taskmanager  
org.apache.flink.runtime.throwable  
org.apache.flink.runtime.topology  
org.apache.flink.runtime.types  
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.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.schema.registry.test  
org.apache.flink.sql.parser
Flink sql parser.
org.apache.flink.sql.parser.ddl  
org.apache.flink.sql.parser.dml  
org.apache.flink.sql.parser.dql  
org.apache.flink.sql.parser.error  
org.apache.flink.sql.parser.impl  
org.apache.flink.sql.parser.type  
org.apache.flink.sql.parser.utils  
org.apache.flink.sql.parser.validate  
org.apache.flink.sql.tests  
org.apache.flink.state.api  
org.apache.flink.state.api.functions  
org.apache.flink.state.api.input  
org.apache.flink.state.api.input.splits  
org.apache.flink.state.api.output  
org.apache.flink.state.api.output.operators  
org.apache.flink.state.api.output.partitioner  
org.apache.flink.state.api.runtime  
org.apache.flink.state.api.runtime.metadata  
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.sink.filesystem  
org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners  
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies  
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.operators.python  
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.elasticsearch6  
org.apache.flink.streaming.connectors.elasticsearch7  
org.apache.flink.streaming.connectors.fs  
org.apache.flink.streaming.connectors.fs.bucketing  
org.apache.flink.streaming.connectors.gcp.pubsub  
org.apache.flink.streaming.connectors.gcp.pubsub.common  
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.kinesis  
org.apache.flink.streaming.connectors.kinesis.config  
org.apache.flink.streaming.connectors.kinesis.internals  
org.apache.flink.streaming.connectors.kinesis.metrics  
org.apache.flink.streaming.connectors.kinesis.model  
org.apache.flink.streaming.connectors.kinesis.proxy  
org.apache.flink.streaming.connectors.kinesis.serialization  
org.apache.flink.streaming.connectors.kinesis.util  
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.gcp.pubsub  
org.apache.flink.streaming.examples.iteration  
org.apache.flink.streaming.examples.iteration.util  
org.apache.flink.streaming.examples.join  
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.kafka.test  
org.apache.flink.streaming.kafka.test.base  
org.apache.flink.streaming.kinesis.test  
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.runtime.tasks.mailbox  
org.apache.flink.streaming.tests  
org.apache.flink.streaming.tests.artificialstate  
org.apache.flink.streaming.tests.artificialstate.builder  
org.apache.flink.streaming.tests.avro  
org.apache.flink.streaming.tests.queryablestate  
org.apache.flink.streaming.tests.util.s3  
org.apache.flink.streaming.tests.verify  
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.api  
org.apache.flink.table.api.config  
org.apache.flink.table.api.dataview  
org.apache.flink.table.api.internal  
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.java.internal  
org.apache.flink.table.calcite  
org.apache.flink.table.catalog  
org.apache.flink.table.catalog.config  
org.apache.flink.table.catalog.exceptions  
org.apache.flink.table.catalog.hive  
org.apache.flink.table.catalog.hive.client  
org.apache.flink.table.catalog.hive.descriptors  
org.apache.flink.table.catalog.hive.factories  
org.apache.flink.table.catalog.hive.util  
org.apache.flink.table.catalog.stats  
org.apache.flink.table.client  
org.apache.flink.table.client.cli  
org.apache.flink.table.client.config  
org.apache.flink.table.client.config.entries  
org.apache.flink.table.client.gateway  
org.apache.flink.table.client.gateway.local  
org.apache.flink.table.client.gateway.local.result  
org.apache.flink.table.dataformat  
org.apache.flink.table.dataformat.util  
org.apache.flink.table.dataformat.vector  
org.apache.flink.table.dataformat.vector.heap  
org.apache.flink.table.dataview  
org.apache.flink.table.delegation  
org.apache.flink.table.descriptors  
org.apache.flink.table.descriptors.python  
org.apache.flink.table.examples.java  
org.apache.flink.table.executor  
org.apache.flink.table.explain  
org.apache.flink.table.expressions  
org.apache.flink.table.expressions.resolver  
org.apache.flink.table.expressions.resolver.lookups  
org.apache.flink.table.expressions.resolver.rules  
org.apache.flink.table.expressions.utils  
org.apache.flink.table.factories  
org.apache.flink.table.functions  
org.apache.flink.table.functions.hive  
org.apache.flink.table.functions.hive.conversion  
org.apache.flink.table.functions.hive.util  
org.apache.flink.table.functions.python  
org.apache.flink.table.module  
org.apache.flink.table.module.hive  
org.apache.flink.table.operations  
org.apache.flink.table.operations.ddl  
org.apache.flink.table.operations.utils  
org.apache.flink.table.operations.utils.factories  
org.apache.flink.table.plan  
org.apache.flink.table.plan.rules.logical  
org.apache.flink.table.plan.stats  
org.apache.flink.table.planner  
org.apache.flink.table.planner.calcite  
org.apache.flink.table.planner.catalog  
org.apache.flink.table.planner.delegation  
org.apache.flink.table.planner.expressions  
org.apache.flink.table.planner.expressions.converter  
org.apache.flink.table.planner.functions  
org.apache.flink.table.planner.functions.aggfunctions  
org.apache.flink.table.planner.functions.sql  
org.apache.flink.table.planner.functions.sql.internal  
org.apache.flink.table.planner.functions.tablefunctions  
org.apache.flink.table.planner.functions.utils  
org.apache.flink.table.planner.operations  
org.apache.flink.table.planner.plan  
org.apache.flink.table.planner.plan.metadata  
org.apache.flink.table.planner.plan.nodes.exec  
org.apache.flink.table.planner.plan.nodes.process  
org.apache.flink.table.planner.plan.nodes.resource  
org.apache.flink.table.planner.plan.rules.logical  
org.apache.flink.table.planner.plan.type  
org.apache.flink.table.planner.plan.utils  
org.apache.flink.table.planner.utils  
org.apache.flink.table.runtime.collector  
org.apache.flink.table.runtime.compression  
org.apache.flink.table.runtime.context  
org.apache.flink.table.runtime.dataview  
org.apache.flink.table.runtime.functions  
org.apache.flink.table.runtime.generated  
org.apache.flink.table.runtime.hashtable  
org.apache.flink.table.runtime.io  
org.apache.flink.table.runtime.keyselector  
org.apache.flink.table.runtime.operators  
org.apache.flink.table.runtime.operators.aggregate  
org.apache.flink.table.runtime.operators.bundle  
org.apache.flink.table.runtime.operators.bundle.trigger  
org.apache.flink.table.runtime.operators.deduplicate  
org.apache.flink.table.runtime.operators.join  
org.apache.flink.table.runtime.operators.join.lookup  
org.apache.flink.table.runtime.operators.join.stream  
org.apache.flink.table.runtime.operators.join.stream.state  
org.apache.flink.table.runtime.operators.join.temporal  
org.apache.flink.table.runtime.operators.match  
org.apache.flink.table.runtime.operators.over  
org.apache.flink.table.runtime.operators.over.frame  
org.apache.flink.table.runtime.operators.python  
org.apache.flink.table.runtime.operators.rank  
org.apache.flink.table.runtime.operators.sort  
org.apache.flink.table.runtime.operators.values  
org.apache.flink.table.runtime.operators.window  
org.apache.flink.table.runtime.operators.window.assigners  
org.apache.flink.table.runtime.operators.window.grouping  
org.apache.flink.table.runtime.operators.window.internal  
org.apache.flink.table.runtime.operators.window.triggers  
org.apache.flink.table.runtime.operators.wmassigners  
org.apache.flink.table.runtime.partitioner  
org.apache.flink.table.runtime.runners.python  
org.apache.flink.table.runtime.types  
org.apache.flink.table.runtime.typeutils  
org.apache.flink.table.runtime.typeutils.serializers.python  
org.apache.flink.table.runtime.util  
org.apache.flink.table.runtime.util.collections  
org.apache.flink.table.sinks  
org.apache.flink.table.sources  
org.apache.flink.table.sources.tsextractors  
org.apache.flink.table.sources.wmstrategies  
org.apache.flink.table.sqlexec  
org.apache.flink.table.toolbox  
org.apache.flink.table.tpch  
org.apache.flink.table.types  
org.apache.flink.table.types.inference  
org.apache.flink.table.types.inference.strategies  
org.apache.flink.table.types.inference.validators  
org.apache.flink.table.types.logical  
org.apache.flink.table.types.logical.utils  
org.apache.flink.table.types.utils  
org.apache.flink.table.typeutils  
org.apache.flink.table.util  
org.apache.flink.table.utils  
org.apache.flink.test  
org.apache.flink.test.testdata  
org.apache.flink.test.util  
org.apache.flink.tests.util  
org.apache.flink.tests.util.activation  
org.apache.flink.tests.util.cache  
org.apache.flink.tests.util.categories  
org.apache.flink.tests.util.flink  
org.apache.flink.tests.util.kafka  
org.apache.flink.tests.util.parameters  
org.apache.flink.tests.util.util  
org.apache.flink.testutils.junit  
org.apache.flink.testutils.junit.category  
org.apache.flink.testutils.oss  
org.apache.flink.testutils.s3  
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.walkthrough.common.entity  
org.apache.flink.walkthrough.common.sink  
org.apache.flink.walkthrough.common.source  
org.apache.flink.walkthrough.common.table  
org.apache.flink.yarn  
org.apache.flink.yarn.cli  
org.apache.flink.yarn.configuration  
org.apache.flink.yarn.entrypoint  
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.