@ConfigurationProperties(value="jdbchdfs") public class JdbcHdfsTaskProperties extends Object
| Modifier and Type | Field and Description |
|---|---|
static int |
DEFAULT_COMMIT_INTERVAL |
static String |
DEFAULT_DELIMITER |
static String |
DEFAULT_DIRECTORY |
static String |
DEFAULT_FILE_EXTENSION |
static String |
DEFAULT_FILE_NAME |
static int |
DEFAULT_MAX_WORKERS |
static int |
DEFAULT_PARTITION_COUNT |
static long |
DEFAULT_ROLLOVER |
| Constructor and Description |
|---|
JdbcHdfsTaskProperties() |
public static final int DEFAULT_PARTITION_COUNT
public static final String DEFAULT_FILE_NAME
public static final long DEFAULT_ROLLOVER
public static final String DEFAULT_DIRECTORY
public static final String DEFAULT_FILE_EXTENSION
public static final String DEFAULT_DELIMITER
public static final int DEFAULT_COMMIT_INTERVAL
public static final int DEFAULT_MAX_WORKERS
public String getFsUri()
public void setFsUri(String fsUri)
public String getPropertiesLocation()
public void setPropertiesLocation(String propertiesLocation)
public String getSecurityMethod()
public void setSecurityMethod(String securityMethod)
public String getUserKeyTab()
public void setUserKeyTab(String userKeyTab)
public String getUserPrincipal()
public void setUserPrincipal(String userPrincipal)
public String getNameNodePrincipal()
public void setNameNodePrincipal(String nameNodePrincipal)
public String getRmManagerPrincipal()
public void setRmManagerPrincipal(String rmManagerPrincipal)
public String getRegisterUrlHandler()
public void setRegisterUrlHandler(String registerUrlHandler)
public int getPartitions()
public void setPartitions(int partitions)
public String getFileName()
public void setFileName(String fileName)
public String getDirectory()
public void setDirectory(String directory)
public String getFileExtension()
public void setFileExtension(String fileExtension)
public long getRollover()
public void setRollover(long rollover)
public String getTableName()
public void setTableName(String tableName)
public String getColumnNames()
public void setColumnNames(String columnNames)
public String getSql()
public void setSql(String sql)
public int getCommitInterval()
public void setCommitInterval(int commitInterval)
public String getDelimiter()
public void setDelimiter(String delimiter)
public String getPartitionColumn()
public void setPartitionColumn(String partitionColumn)
public String getCheckColumn()
public void setCheckColumn(String checkColumn)
public boolean isRestartable()
public void setRestartable(boolean restartable)
public int getMaxWorkers()
public void setMaxWorkers(int maxWorkers)
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.