hasis Sinha
#
package Apache::Hadoop::Watcher::Yarn;
use 5.010001;
use strict;
use warnings;
use JSON;
require Apache::Hadoop::Watcher::Base;
our @ISA = qw();
our $VERSION = '0.01';
# Preloaded m
,"\n" if $self->{'debug'};
# actual work
$self->{'out'} = (decode_json $base->_wget (url=>$url)); #->{'nodeInfo'};
$base->_jsontr ( $self->{'out'} );
return $self;
}
1;
__END__
=head1 NAME
Ap
ckage Apache::Hadoop::Watcher::Conf;
use 5.010001;
use strict;
use warnings;
use XML::Twig;
use JSON;
require Apache::Hadoop::Watcher::Base;
our @ISA = qw();
our $VERSION = '0.01';
# methods
sub
ations
=head1 SEE ALSO
Apache::Hadoop::Watcher
Apache::Hadoop::Watcher::Base
XML::Twig
JSON
=head1 AUTHOR
Snehasis Sinha, E<lt>snehasis@cpan.orgE<gt>
=head1 COPYRIGHT AND LICENSE
Copy
# changing json boolean object to perl values
sub _jsontr {
my ($self, $hash) = (@_);
foreach my $v ( values %{$hash} ) {
$v = ($v ? 'true' : 'false') if ref $v eq 'JSON::PP::Boolean
';
$self->_jsontr ( $v ) if ref $v eq 'HASH';
}
#return $hash;
}
sub _jsonjmx {
my ($self, $hook) = (@_);
if ( ref $hook eq 'HASH' ) {
$self->_jsontr ( $hook );
}
if ( ref $hook
eq 'ARRAY' ) {
foreach my $e ( @$hook ) {
$self->_jsontr ( $e );
}
}
}
# dumps output hashref
sub _print {
my ($self, %opts) = (@_);
print Dumper ( $opts{'output'} );
}
1;
__END__
hasis Sinha
#
package Apache::Hadoop::Watcher::Jmx;
use 5.010001;
use strict;
use warnings;
use JSON;
require Apache::Hadoop::Watcher::Base;
our @ISA = qw();
our $VERSION = '0.01';
# Preloaded m
' ', $_;
}
next;
}
print sprintf "%30s %s\n", $e->{'key'}, $e->{'value'};
}
}
# jmx json methods
sub _query {
my ($self, %opts) = (@_);
my $base = Apache::Hadoop::Watcher::Base->new;
$self->{'jmx'};
$self->{'out'} = (decode_json $base->_wget (url=>$url))->{'beans'};
#$self->{'out'} = (decode_json $base->_wget (url=>$url));
$base->_jsonjmx ( $self->{'out'} );
$self->{'out'} =~