@@ -108,39 +108,50 @@ public static OzoneVolume createVolume(OzoneClient client,
108
108
public static void createKey (OzoneBucket bucket , String keyName ,
109
109
String content ) throws IOException {
110
110
createKey (bucket , keyName , ReplicationFactor .ONE ,
111
- ReplicationType .RATIS , content );
111
+ ReplicationType .RATIS , content . getBytes ( UTF_8 ) );
112
112
}
113
113
114
114
public static void createKey (OzoneBucket bucket , String keyName ,
115
115
byte [] content ) throws IOException {
116
116
createKey (bucket , keyName , ReplicationFactor .ONE ,
117
- ReplicationType .RATIS , new String (content , UTF_8 ));
117
+ ReplicationType .RATIS , content );
118
+
118
119
}
119
120
120
121
public static void createKey (OzoneBucket bucket , String keyName ,
121
122
ReplicationFactor repFactor , ReplicationType repType , byte [] content )
122
123
throws IOException {
123
124
ReplicationConfig repConfig = ReplicationConfig
124
125
.fromTypeAndFactor (repType , repFactor );
125
- createKey (bucket , keyName , repConfig , new String (content , UTF_8 ));
126
+ try (OutputStream stream = bucket
127
+ .createKey (keyName , content .length , repConfig ,
128
+ new HashMap <>())) {
129
+ stream .write (content );
130
+ }
131
+ }
132
+
133
+ public static void createKey (OzoneBucket bucket , String keyName ,
134
+ ReplicationConfig repConfig , byte [] content )
135
+ throws IOException {
136
+ try (OutputStream stream = bucket
137
+ .createKey (keyName , content .length , repConfig ,
138
+ new HashMap <>())) {
139
+ stream .write (content );
140
+ }
126
141
}
127
142
128
143
public static void createKey (OzoneBucket bucket , String keyName ,
129
144
ReplicationFactor repFactor , ReplicationType repType , String content )
130
145
throws IOException {
131
146
ReplicationConfig repConfig = ReplicationConfig
132
147
.fromTypeAndFactor (repType , repFactor );
133
- createKey (bucket , keyName , repConfig , content );
148
+ createKey (bucket , keyName , repConfig , content . getBytes ( UTF_8 ) );
134
149
}
135
150
136
151
public static void createKey (OzoneBucket bucket , String keyName ,
137
152
ReplicationConfig repConfig , String content )
138
153
throws IOException {
139
- try (OutputStream stream = bucket
140
- .createKey (keyName , content .length (), repConfig ,
141
- new HashMap <>())) {
142
- stream .write (content .getBytes (UTF_8 ));
143
- }
154
+ createKey (bucket , keyName , repConfig , content .getBytes (UTF_8 ));
144
155
}
145
156
146
157
public static void createKey (OzoneBucket bucket , String keyName ,
0 commit comments