@Internal public class KubernetesSessionClusterExecutor extends AbstractSessionClusterExecutor<String,KubernetesClusterClientFactory>
PipelineExecutor
to be used when executing a job on an already running cluster.Constructor and Description |
---|
KubernetesSessionClusterExecutor(Configuration configuration) |
execute, invalidateClusterDataset, listCompletedClusterDatasetIds
public static final String NAME
public KubernetesSessionClusterExecutor(Configuration configuration)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.