2016-12-20 23 views
1

私はスプリングバッチ実装でデータをインデックス化するelasticsearchのカスタムライターを作成しようとしています。SpringバッチでElasticsearch java configクライアントを使用

私はelasticsearchのJava設定として以下のコードを見つけることができました。

誰でもこの設定を使用している人は、この設定をどこから共有することができますか?すなわち、これは春のデータを使用して、永続的な層を定義するElasticsearch Serverのインスタンスを指して交通クライアント要素 -

@Configuration 
    @EnableElasticsearchRepositories(basePackages = "org/springframework/data/elasticsearch/repositories") 
     static class Config { 

     @Value("${esearch.port}") int port; 
     @Value("${esearch.host}") String hostname; 

     @Bean 
     public ElasticsearchOperations elasticsearchTemplate() { 
     return new ElasticsearchTemplate(client()); 
     } 

     @Bean 
     public Client client(){ 
      TransportClient client= new TransportClient(); 
      TransportAddress address = new InetSocketTransportAddress(hostname, port); 
      client.addTransportAddress(address); 
      return client; 
     } 
    } 

答えて

0

あなたは上記のコードでは、基本的にはあなたの実装の詳細です。

このコードは、elasticsearchリポジトリ、つまりSpringデータから-を拡張して定義したリポジトリで使用されます。

@EnableElasticsearchRepositoriesのコードを編集して、リポジトリ定義を保持しているパッケージを実際に指すようにしてください。他の呼び出しは必要ありません。

elasticsearchにデータを書き込む場合はElasticsearchRepositoryインターフェイスで作業し、独自のリポジトリを定義する必要があります。これらのリポジトリはコード内のインスタンスごとに動作します。

希望すると助かります!

関連する問題