public class XdEnvironment
extends java.lang.Object
implements org.springframework.beans.factory.BeanClassLoaderAware| 修飾子と型 | フィールドと説明 |
|---|---|
static java.lang.String | HTTP_PREFIX |
static java.lang.String | RESULT_LOCATION |
static java.lang.String | XD_ADMIN_HOST |
static java.lang.String | XD_HTTP_PORT |
static java.lang.String | XD_JMX_PORT |
| コンストラクターと説明 |
|---|
XdEnvironment() |
| 修飾子と型 | メソッドと説明 |
|---|---|
java.net.URL | getAdminServerUrl() |
java.lang.String | getBaseDir() |
java.lang.String | getContainerLogLocation() |
java.lang.String | getDataNodePort() この環境で使用できる Hadoop データノードポート。 |
javax.sql.DataSource | getDataSource() |
java.lang.String | getGemfireHost()Gemfire ホストを取得します。 |
int | getGemfirePort()Gemfire ポートを取得します。 |
int | getHttpPort() |
java.lang.String | getJmsHost() |
int | getJmsPort() |
int | getJmxPort() |
java.lang.String | getKafkaBrokerList()Kafka ブローカーリストを取得します。 |
java.lang.String | getKafkaZkConnect()Kafka ZK 接続文字列を取得します。 |
org.springframework.data.mongodb.MongoDbFactory | getMongoDbFactory() テストに使用する mongo db ファクトリ。 |
java.lang.String | getMongoHost()mongo サーバーが実行されているホストを取得します。 |
java.lang.String | getMongoPort()mongo サーバーが監視しているポートを取得します。 |
java.lang.String | getNameNode() この環境で使用できる Hadoop 名ノード。 |
java.lang.String | getPrivateKey() |
org.springframework.amqp.rabbit.connection.CachingConnectionFactory | getRabbitConnectionFactory() |
java.lang.String | getRabbitMQHost() デフォルト値は管理サーバーホストと同じです。 |
java.lang.String | getSparkAppJar()SparkApp Jar の位置を取得します |
java.lang.String | getSparkAppJarSource() テストに使用する Spark アプリ jar の場所を取得します。 |
java.lang.String | getSparkAppMainClass()Spark アプリの package.class を取得します |
java.lang.String | getSparkAppName()Spark アプリに関連付けられた名前を取得します |
java.lang.String | getSparkMaster()Spark マスターの URI(spark://host:port またはローカル設定(local[x])を取得します |
java.lang.String | getTcpClientHost()TCP クライアントホストを取得します。 |
int | getTcpClientPort()TCP クライアントポートを取得します。 |
java.lang.String | getTwitterAccessToken()Twitter アクセストークン |
java.lang.String | getTwitterAccessTokenSecret()Twitter アクセストークンの秘密 |
java.lang.String | getTwitterConsumerKey()Twitter のコンシューマーキー |
java.lang.String | getTwitterConsumerSecretKey()Twitter コンシューマー秘密鍵 |
void | initalizeEc2Environment() ローカル XD インスタンスでテストを実行していない場合は、アーティファクトから情報を取得し、リモート XD に対してテストするための環境を設定します。 |
boolean | isOnEc2() |
void | setBeanClassLoader(java.lang.ClassLoader beanClassLoader) |
public static final java.lang.String XD_ADMIN_HOST
public static final java.lang.String XD_HTTP_PORT
public static final java.lang.String XD_JMX_PORT
public static final java.lang.String RESULT_LOCATION
public static final java.lang.String HTTP_PREFIX
@PostConstruct
public void initalizeEc2Environment()
throws java.net.MalformedURLExceptionjava.net.MalformedURLExceptionpublic void setBeanClassLoader(java.lang.ClassLoader beanClassLoader)
org.springframework.beans.factory.BeanClassLoaderAware 内の setBeanClassLoader public java.net.URL getAdminServerUrl()
public int getJmxPort()
public int getHttpPort()
public java.lang.String getPrivateKey()
public boolean isOnEc2()
public java.lang.String getContainerLogLocation()
public java.lang.String getBaseDir()
public javax.sql.DataSource getDataSource()
public org.springframework.amqp.rabbit.connection.CachingConnectionFactory getRabbitConnectionFactory()
public java.lang.String getJmsHost()
public int getJmsPort()
public java.lang.String getRabbitMQHost()
public java.lang.String getTwitterConsumerKey()
public java.lang.String getTwitterConsumerSecretKey()
public java.lang.String getTwitterAccessToken()
public java.lang.String getTwitterAccessTokenSecret()
public java.lang.String getNameNode()
public java.lang.String getDataNodePort()
public org.springframework.data.mongodb.MongoDbFactory getMongoDbFactory()
public java.lang.String getMongoHost()
public java.lang.String getMongoPort()
public java.lang.String getGemfireHost()
public int getGemfirePort()
public java.lang.String getKafkaBrokerList()
public java.lang.String getKafkaZkConnect()
public int getTcpClientPort()
public java.lang.String getTcpClientHost()
public java.lang.String getSparkAppName()
public java.lang.String getSparkAppJar()
public java.lang.String getSparkMaster()
public java.lang.String getSparkAppMainClass()
public java.lang.String getSparkAppJarSource()