コンストラクターの詳細

• Jobs

  public Jobs(XdEnvironment environment)

  xdEnvironment でインスタンスを初期化する

  パラメーター:

  environment -

メソッドの詳細

• fileJdbcJob

  public FileJdbcJob fileJdbcJob()

  デフォルトのターゲットディレクトリ、fileName、tableName、列名を使用して、FileJdbc ジョブのインスタンスを作成します。

  戻り値:

  FileJDBCJob フィクスチャのインスタンス。

  関連事項:

  for default values

• hdfsJdbcJob

  public HdfsJdbcJob hdfsJdbcJob()

  デフォルトのターゲットディレクトリ、fileName、tableName、列名を使用して、HdfsJdbc ジョブのインスタンスを作成します。

  戻り値:

  HdfsJDBCJob フィクスチャのインスタンス。

  関連事項:

  for default values

• jdbcHdfsJob

  public JdbcHdfsJob jdbcHdfsJob()

  デフォルトの HDFs ターゲットディレクトリ、fileName、ソース SQL ステートメントを使用して、JdbcHdfs ジョブのインスタンスを作成します。

  戻り値:

  JdbcHdfsJob フィクスチャのインスタンス。

  関連事項:

  for default values

• incrementalJdbcHdfsJob

  public IncrementalJdbcHdfsJob incrementalJdbcHdfsJob()

  デフォルトの HDFs ターゲットディレクトリ、fileName、ソース SQL ステートメントを使用して、JdbcHdfs ジョブのインスタンスを作成します。

  戻り値:

  JdbcHdfsJob フィクスチャのインスタンス。

  関連事項:

  for default values

• partitionedJdbcHdfsJob

  public PartitionedJdbcHdfsJob partitionedJdbcHdfsJob()

  デフォルトの hdfs ターゲットディレクトリ、fileName、テーブル、columnNames、partitionColumn、パーティションを使用して、PartitionedJdbcHdfsJob ジョブのインスタンスを作成します。

  戻り値:

  PartitionedJdbcHdfsJob フィクスチャのインスタンス。

  関連事項:

  for default values

• filePollHdfsJob

  public FilePollHdfsJob filePollHdfsJob(java.lang.String names)

  デフォルトを使用して FilePollHdfsJob のインスタンスを作成します。

  パラメーター:

  names - 列名のカンマ区切りリスト

  戻り値:

  FilePollHdfsJob フィクスチャのインスタンス。

• hdfsMongoDb

  public HdfsMongoDbJob hdfsMongoDb()

  HDF からデータを読み取り、デフォルト値を使用して mongo に出力するジョブを構築する新しい HdfsMongoDbJob を作成します。MongoDB サーバーに接続できることを確認します。

  戻り値:

  HdfsMongoDbJob インスタンス。

• ftpHdfsJob

  public FtpHdfsJob ftpHdfsJob()

  デフォルトを使用して FtpHdfsJob フィクスチャを作成します。

  戻り値:

  FtpHdfsJob インスタンス

• sparkAppJob

  public SparkAppJob sparkAppJob()

  プロパティファイルまたは環境変数を使用して構成される新しい SparkAppJob フィクスチャインスタンスを作成します。

  戻り値:

  SparkAppJob インスタンス