Class PlanRun
- java.lang.Object
-
- io.github.datacatering.datacaterer.javaapi.api.PlanRun
-
public abstract class PlanRun extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description PlanRun()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.github.datacatering.datacaterer.api.connection.CassandraBuildercassandra(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<io.github.datacatering.datacaterer.api.connection.CassandraBuilder> connectionTaskBuilder)io.github.datacatering.datacaterer.api.connection.CassandraBuildercassandra(java.lang.String name, java.lang.String url)io.github.datacatering.datacaterer.api.connection.CassandraBuildercassandra(java.lang.String name, java.lang.String url, java.lang.String username, java.lang.String password, java.util.Map<java.lang.String,java.lang.String> options)io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilderconfiguration()io.github.datacatering.datacaterer.api.CountBuildercount()io.github.datacatering.datacaterer.api.connection.FileBuildercsv(java.lang.String name, java.lang.String path)io.github.datacatering.datacaterer.api.connection.FileBuildercsv(java.lang.String name, java.lang.String path, java.util.Map<java.lang.String,java.lang.String> options)io.github.datacatering.datacaterer.api.DataSourceValidationBuilderdataSourceValidation()voidexecute(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?> connectionTaskBuilder, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?>... connectionTaskBuilders)voidexecute(io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilder configurationBuilder)voidexecute(io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilder configurationBuilder, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?> connectionTaskBuilder, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?>... connectionTaskBuilders)voidexecute(io.github.datacatering.datacaterer.api.PlanBuilder plan, io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilder configuration)voidexecute(io.github.datacatering.datacaterer.api.PlanBuilder planBuilder, io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilder configurationBuilder, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?> connectionTaskBuilder, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?>... connectionTaskBuilders)voidexecute(io.github.datacatering.datacaterer.api.PlanBuilder planBuilder, io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilder configurationBuilder, java.util.List<io.github.datacatering.datacaterer.api.ValidationConfigurationBuilder> validations, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?> connectionTaskBuilder, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?>... connectionTaskBuilders)voidexecute(io.github.datacatering.datacaterer.api.TasksBuilder tasks)voidexecute(java.util.List<io.github.datacatering.datacaterer.api.TasksBuilder> tasks, io.github.datacatering.datacaterer.api.PlanBuilder plan, io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilder configuration, java.util.List<io.github.datacatering.datacaterer.api.ValidationConfigurationBuilder> validations)io.github.datacatering.datacaterer.api.FieldBuilderfield()io.github.datacatering.datacaterer.api.model.ForeignKeyRelationforeignField(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?> connectionTaskBuilder, java.lang.String step, java.util.List<java.lang.String> columns)io.github.datacatering.datacaterer.api.model.ForeignKeyRelationforeignField(java.lang.String dataSource, java.lang.String step, java.lang.String column)io.github.datacatering.datacaterer.api.model.ForeignKeyRelationforeignField(java.lang.String dataSource, java.lang.String step, java.util.List<java.lang.String> columns)io.github.datacatering.datacaterer.api.GeneratorBuildergenerator()io.github.datacatering.datacaterer.api.PlanRungetPlan()io.github.datacatering.datacaterer.api.connection.HttpBuilderhttp(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<io.github.datacatering.datacaterer.api.connection.HttpBuilder> connectionTaskBuilder)io.github.datacatering.datacaterer.api.connection.HttpBuilderhttp(java.lang.String name)io.github.datacatering.datacaterer.api.connection.HttpBuilderhttp(java.lang.String name, java.lang.String username, java.lang.String password, java.util.Map<java.lang.String,java.lang.String> options)io.github.datacatering.datacaterer.api.connection.HttpBuilderhttp(java.lang.String name, java.util.Map<java.lang.String,java.lang.String> options)io.github.datacatering.datacaterer.api.connection.FileBuilderjson(java.lang.String name, java.lang.String path)io.github.datacatering.datacaterer.api.connection.FileBuilderjson(java.lang.String name, java.lang.String path, java.util.Map<java.lang.String,java.lang.String> options)io.github.datacatering.datacaterer.api.connection.KafkaBuilderkafka(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<io.github.datacatering.datacaterer.api.connection.KafkaBuilder> connectionTaskBuilder)io.github.datacatering.datacaterer.api.connection.KafkaBuilderkafka(java.lang.String name, java.lang.String url)io.github.datacatering.datacaterer.api.connection.KafkaBuilderkafka(java.lang.String name, java.lang.String url, java.util.Map<java.lang.String,java.lang.String> options)io.github.datacatering.datacaterer.api.MetadataSourceBuildermetadataSource()io.github.datacatering.datacaterer.api.connection.MySqlBuildermysql(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<io.github.datacatering.datacaterer.api.connection.MySqlBuilder> connectionTaskBuilder)io.github.datacatering.datacaterer.api.connection.MySqlBuildermysql(java.lang.String name, java.lang.String url)io.github.datacatering.datacaterer.api.connection.MySqlBuildermysql(java.lang.String name, java.lang.String url, java.lang.String username, java.lang.String password, java.util.Map<java.lang.String,java.lang.String> options)io.github.datacatering.datacaterer.api.connection.FileBuilderorc(java.lang.String name, java.lang.String path)io.github.datacatering.datacaterer.api.connection.FileBuilderorc(java.lang.String name, java.lang.String path, java.util.Map<java.lang.String,java.lang.String> options)io.github.datacatering.datacaterer.api.connection.FileBuilderparquet(java.lang.String name, java.lang.String path)io.github.datacatering.datacaterer.api.connection.FileBuilderparquet(java.lang.String name, java.lang.String path, java.util.Map<java.lang.String,java.lang.String> options)io.github.datacatering.datacaterer.api.PlanBuilderplan()io.github.datacatering.datacaterer.api.connection.PostgresBuilderpostgres(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<io.github.datacatering.datacaterer.api.connection.PostgresBuilder> connectionTaskBuilder)io.github.datacatering.datacaterer.api.connection.PostgresBuilderpostgres(java.lang.String name, java.lang.String url)io.github.datacatering.datacaterer.api.connection.PostgresBuilderpostgres(java.lang.String name, java.lang.String url, java.lang.String username, java.lang.String password, java.util.Map<java.lang.String,java.lang.String> options)io.github.datacatering.datacaterer.api.SchemaBuilderschema()io.github.datacatering.datacaterer.api.connection.SolaceBuildersolace(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<io.github.datacatering.datacaterer.api.connection.SolaceBuilder> connectionTaskBuilder)io.github.datacatering.datacaterer.api.connection.SolaceBuildersolace(java.lang.String name, java.lang.String url)io.github.datacatering.datacaterer.api.connection.SolaceBuildersolace(java.lang.String name, java.lang.String url, java.lang.String username, java.lang.String password, java.lang.String vpnName)io.github.datacatering.datacaterer.api.connection.SolaceBuildersolace(java.lang.String name, java.lang.String url, java.lang.String username, java.lang.String password, java.lang.String vpnName, java.lang.String connectionFactory, java.lang.String initialContextFactory, java.util.Map<java.lang.String,java.lang.String> options)io.github.datacatering.datacaterer.api.StepBuilderstep()io.github.datacatering.datacaterer.api.TaskBuildertask()io.github.datacatering.datacaterer.api.TasksBuildertasks()io.github.datacatering.datacaterer.api.TaskSummaryBuildertaskSummary()io.github.datacatering.datacaterer.api.ValidationBuildervalidation()io.github.datacatering.datacaterer.api.ValidationConfigurationBuildervalidationConfig()io.github.datacatering.datacaterer.api.WaitConditionBuilderwaitCondition()
-
-
-
Method Detail
-
getPlan
public io.github.datacatering.datacaterer.api.PlanRun getPlan()
-
plan
public io.github.datacatering.datacaterer.api.PlanBuilder plan()
-
taskSummary
public io.github.datacatering.datacaterer.api.TaskSummaryBuilder taskSummary()
-
tasks
public io.github.datacatering.datacaterer.api.TasksBuilder tasks()
-
task
public io.github.datacatering.datacaterer.api.TaskBuilder task()
-
step
public io.github.datacatering.datacaterer.api.StepBuilder step()
-
schema
public io.github.datacatering.datacaterer.api.SchemaBuilder schema()
-
field
public io.github.datacatering.datacaterer.api.FieldBuilder field()
-
generator
public io.github.datacatering.datacaterer.api.GeneratorBuilder generator()
-
count
public io.github.datacatering.datacaterer.api.CountBuilder count()
-
configuration
public io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilder configuration()
-
waitCondition
public io.github.datacatering.datacaterer.api.WaitConditionBuilder waitCondition()
-
validation
public io.github.datacatering.datacaterer.api.ValidationBuilder validation()
-
dataSourceValidation
public io.github.datacatering.datacaterer.api.DataSourceValidationBuilder dataSourceValidation()
-
validationConfig
public io.github.datacatering.datacaterer.api.ValidationConfigurationBuilder validationConfig()
-
metadataSource
public io.github.datacatering.datacaterer.api.MetadataSourceBuilder metadataSource()
-
foreignField
public io.github.datacatering.datacaterer.api.model.ForeignKeyRelation foreignField(java.lang.String dataSource, java.lang.String step, java.lang.String column)
-
foreignField
public io.github.datacatering.datacaterer.api.model.ForeignKeyRelation foreignField(java.lang.String dataSource, java.lang.String step, java.util.List<java.lang.String> columns)
-
foreignField
public io.github.datacatering.datacaterer.api.model.ForeignKeyRelation foreignField(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?> connectionTaskBuilder, java.lang.String step, java.util.List<java.lang.String> columns)
-
csv
public io.github.datacatering.datacaterer.api.connection.FileBuilder csv(java.lang.String name, java.lang.String path, java.util.Map<java.lang.String,java.lang.String> options)
-
csv
public io.github.datacatering.datacaterer.api.connection.FileBuilder csv(java.lang.String name, java.lang.String path)
-
json
public io.github.datacatering.datacaterer.api.connection.FileBuilder json(java.lang.String name, java.lang.String path, java.util.Map<java.lang.String,java.lang.String> options)
-
json
public io.github.datacatering.datacaterer.api.connection.FileBuilder json(java.lang.String name, java.lang.String path)
-
orc
public io.github.datacatering.datacaterer.api.connection.FileBuilder orc(java.lang.String name, java.lang.String path, java.util.Map<java.lang.String,java.lang.String> options)
-
orc
public io.github.datacatering.datacaterer.api.connection.FileBuilder orc(java.lang.String name, java.lang.String path)
-
parquet
public io.github.datacatering.datacaterer.api.connection.FileBuilder parquet(java.lang.String name, java.lang.String path, java.util.Map<java.lang.String,java.lang.String> options)
-
parquet
public io.github.datacatering.datacaterer.api.connection.FileBuilder parquet(java.lang.String name, java.lang.String path)
-
postgres
public io.github.datacatering.datacaterer.api.connection.PostgresBuilder postgres(java.lang.String name, java.lang.String url, java.lang.String username, java.lang.String password, java.util.Map<java.lang.String,java.lang.String> options)
-
postgres
public io.github.datacatering.datacaterer.api.connection.PostgresBuilder postgres(java.lang.String name, java.lang.String url)
-
postgres
public io.github.datacatering.datacaterer.api.connection.PostgresBuilder postgres(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<io.github.datacatering.datacaterer.api.connection.PostgresBuilder> connectionTaskBuilder)
-
mysql
public io.github.datacatering.datacaterer.api.connection.MySqlBuilder mysql(java.lang.String name, java.lang.String url, java.lang.String username, java.lang.String password, java.util.Map<java.lang.String,java.lang.String> options)
-
mysql
public io.github.datacatering.datacaterer.api.connection.MySqlBuilder mysql(java.lang.String name, java.lang.String url)
-
mysql
public io.github.datacatering.datacaterer.api.connection.MySqlBuilder mysql(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<io.github.datacatering.datacaterer.api.connection.MySqlBuilder> connectionTaskBuilder)
-
cassandra
public io.github.datacatering.datacaterer.api.connection.CassandraBuilder cassandra(java.lang.String name, java.lang.String url, java.lang.String username, java.lang.String password, java.util.Map<java.lang.String,java.lang.String> options)
-
cassandra
public io.github.datacatering.datacaterer.api.connection.CassandraBuilder cassandra(java.lang.String name, java.lang.String url)
-
cassandra
public io.github.datacatering.datacaterer.api.connection.CassandraBuilder cassandra(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<io.github.datacatering.datacaterer.api.connection.CassandraBuilder> connectionTaskBuilder)
-
solace
public io.github.datacatering.datacaterer.api.connection.SolaceBuilder solace(java.lang.String name, java.lang.String url, java.lang.String username, java.lang.String password, java.lang.String vpnName, java.lang.String connectionFactory, java.lang.String initialContextFactory, java.util.Map<java.lang.String,java.lang.String> options)
-
solace
public io.github.datacatering.datacaterer.api.connection.SolaceBuilder solace(java.lang.String name, java.lang.String url, java.lang.String username, java.lang.String password, java.lang.String vpnName)
-
solace
public io.github.datacatering.datacaterer.api.connection.SolaceBuilder solace(java.lang.String name, java.lang.String url)
-
solace
public io.github.datacatering.datacaterer.api.connection.SolaceBuilder solace(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<io.github.datacatering.datacaterer.api.connection.SolaceBuilder> connectionTaskBuilder)
-
kafka
public io.github.datacatering.datacaterer.api.connection.KafkaBuilder kafka(java.lang.String name, java.lang.String url, java.util.Map<java.lang.String,java.lang.String> options)
-
kafka
public io.github.datacatering.datacaterer.api.connection.KafkaBuilder kafka(java.lang.String name, java.lang.String url)
-
kafka
public io.github.datacatering.datacaterer.api.connection.KafkaBuilder kafka(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<io.github.datacatering.datacaterer.api.connection.KafkaBuilder> connectionTaskBuilder)
-
http
public io.github.datacatering.datacaterer.api.connection.HttpBuilder http(java.lang.String name, java.lang.String username, java.lang.String password, java.util.Map<java.lang.String,java.lang.String> options)
-
http
public io.github.datacatering.datacaterer.api.connection.HttpBuilder http(java.lang.String name, java.util.Map<java.lang.String,java.lang.String> options)
-
http
public io.github.datacatering.datacaterer.api.connection.HttpBuilder http(java.lang.String name)
-
http
public io.github.datacatering.datacaterer.api.connection.HttpBuilder http(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<io.github.datacatering.datacaterer.api.connection.HttpBuilder> connectionTaskBuilder)
-
execute
public void execute(io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?> connectionTaskBuilder, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?>... connectionTaskBuilders)
-
execute
public void execute(io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilder configurationBuilder, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?> connectionTaskBuilder, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?>... connectionTaskBuilders)
-
execute
public void execute(io.github.datacatering.datacaterer.api.PlanBuilder planBuilder, io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilder configurationBuilder, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?> connectionTaskBuilder, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?>... connectionTaskBuilders)
-
execute
public void execute(io.github.datacatering.datacaterer.api.PlanBuilder planBuilder, io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilder configurationBuilder, java.util.List<io.github.datacatering.datacaterer.api.ValidationConfigurationBuilder> validations, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?> connectionTaskBuilder, io.github.datacatering.datacaterer.api.connection.ConnectionTaskBuilder<?>... connectionTaskBuilders)
-
execute
public void execute(io.github.datacatering.datacaterer.api.TasksBuilder tasks)
-
execute
public void execute(io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilder configurationBuilder)
-
execute
public void execute(io.github.datacatering.datacaterer.api.PlanBuilder plan, io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilder configuration)
-
execute
public void execute(java.util.List<io.github.datacatering.datacaterer.api.TasksBuilder> tasks, io.github.datacatering.datacaterer.api.PlanBuilder plan, io.github.datacatering.datacaterer.api.DataCatererConfigurationBuilder configuration, java.util.List<io.github.datacatering.datacaterer.api.ValidationConfigurationBuilder> validations)
-
-