3535import org .elasticsearch .xcontent .XContentBuilder ;
3636import org .elasticsearch .xpack .core .inference .results .ChunkedInferenceEmbedding ;
3737import org .elasticsearch .xpack .core .inference .results .SparseEmbeddingResults ;
38- import org .elasticsearch .xpack .core .inference .results .TextEmbeddingFloatResults ;
3938import org .elasticsearch .xpack .core .ml .search .WeightedToken ;
4039
4140import java .io .IOException ;
@@ -64,7 +63,7 @@ public TestSparseModel(String inferenceEntityId, TestServiceSettings serviceSett
6463 public static class TestInferenceService extends AbstractTestInferenceService {
6564 public static final String NAME = "test_service" ;
6665
67- private static final EnumSet <TaskType > supportedTaskTypes = EnumSet .of (TaskType .SPARSE_EMBEDDING , TaskType . TEXT_EMBEDDING );
66+ private static final EnumSet <TaskType > supportedTaskTypes = EnumSet .of (TaskType .SPARSE_EMBEDDING );
6867
6968 public TestInferenceService (InferenceServiceExtension .InferenceServiceFactoryContext context ) {}
7069
@@ -115,8 +114,7 @@ public void infer(
115114 ActionListener <InferenceServiceResults > listener
116115 ) {
117116 switch (model .getConfigurations ().getTaskType ()) {
118- case ANY , SPARSE_EMBEDDING -> listener .onResponse (makeSparseEmbeddingResults (input ));
119- case TEXT_EMBEDDING -> listener .onResponse (makeTextEmbeddingResults (input ));
117+ case ANY , SPARSE_EMBEDDING -> listener .onResponse (makeResults (input ));
120118 default -> listener .onFailure (
121119 new ElasticsearchStatusException (
122120 TaskType .unsupportedTaskTypeErrorMsg (model .getConfigurations ().getTaskType (), name ()),
@@ -157,7 +155,7 @@ public void chunkedInfer(
157155 }
158156 }
159157
160- private SparseEmbeddingResults makeSparseEmbeddingResults (List <String > input ) {
158+ private SparseEmbeddingResults makeResults (List <String > input ) {
161159 var embeddings = new ArrayList <SparseEmbeddingResults .Embedding >();
162160 for (int i = 0 ; i < input .size (); i ++) {
163161 var tokens = new ArrayList <WeightedToken >();
@@ -169,18 +167,6 @@ private SparseEmbeddingResults makeSparseEmbeddingResults(List<String> input) {
169167 return new SparseEmbeddingResults (embeddings );
170168 }
171169
172- private TextEmbeddingFloatResults makeTextEmbeddingResults (List <String > input ) {
173- var embeddings = new ArrayList <TextEmbeddingFloatResults .Embedding >();
174- for (int i = 0 ; i < input .size (); i ++) {
175- var values = new float [5 ];
176- for (int j = 0 ; j < 5 ; j ++) {
177- values [j ] = random .nextFloat ();
178- }
179- embeddings .add (new TextEmbeddingFloatResults .Embedding (values ));
180- }
181- return new TextEmbeddingFloatResults (embeddings );
182- }
183-
184170 private List <ChunkedInference > makeChunkedResults (List <ChunkInferenceInput > inputs ) {
185171 List <ChunkedInference > results = new ArrayList <>();
186172 for (ChunkInferenceInput chunkInferenceInput : inputs ) {
0 commit comments