Bulk Operation

FLINK-19343 Introduce CacheManager in CatalogManager to keep track of the ClusterPartitionDescriptor

FLINK-19343 Add close() method to TableEnvironment

FLINK-19343 Add invalidateCache() method in CachedTable

FLINK-19343 BlinkPlanner translate and optimize CacheOperation

FLINK-19343 Add cache() method to Table

FLINK-19343 StreamingJobGraphGenerator set the caching node to BoundedBlockingType

FLINK-19343 StreamingJobGraphGenerator add the ClusterPartitionDescriptor of cached node to JobVertex

FLINK-19343 StreamGraphGenerator handle CacheSource and CacheSink

FLINK-19343 Introduce CacheSource and CacheSink

FLINK-19343 Generate InputGateDeploymentDescriptor from a JobVertex with ClusterPartitionDescriptor

FLINK-19343 Generate and put ClusterPartitionDescriptor of ClusterPartition in JobResult when job finishes