package org.springblade.etl.engine.flink.client.session;

import java.nio.file.Path;

import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.client.program.ClusterClient;
import org.apache.flink.configuration.Configuration;

public interface SessionCommand {

	Tuple2<String, ClusterClient> create(Path flinkHome, Configuration configuration) throws Exception;
}
