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