3f4fd0b297082935046e76f4a69494081fec086a
2 * Licensed to the Apache Software Foundation (ASF) under one
3 * or more contributor license agreements. See the NOTICE file
4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
6 * to you under the Apache License, Version 2.0 (the
7 * "License"); you may not use this file except in compliance
8 * with the License. You may obtain a copy of the License at
10 * http://www.apache.org/licenses/LICENSE-2.0
12 * Unless required by applicable law or agreed to in writing,
13 * software distributed under the License is distributed on an
14 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15 * KIND, either express or implied. See the License for the
16 * specific language governing permissions and limitations
20 package org
.apache
.samza
.zk
;
22 import org
.apache
.samza
.SamzaException
;
25 public class ProcessorData
{
26 private final String processorId
;
27 private final String host
;
29 public ProcessorData(String host
, String processorId
) {
30 this.processorId
= processorId
;
34 public ProcessorData(String data
) {
35 String
[] splt
= data
.split(" ");
36 if (splt
.length
!= 2) {
37 throw new SamzaException("incorrect processor data format = " + data
);
40 processorId
= splt
[1];
43 public String
toString() {
44 return host
+ " " + processorId
;
47 public String
getHost() {
51 public String
getProcessorId() {